diff --git a/runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/BatchModeExecutionContextTest.java b/runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/BatchModeExecutionContextTest.java
index 4062fbf6ebed..d3fa69e2c31c 100644
--- a/runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/BatchModeExecutionContextTest.java
+++ b/runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/BatchModeExecutionContextTest.java
@@ -187,7 +187,7 @@ public void extractMetricUpdatesStringSet() {
                             .setName("some-stringset")
                             .setOriginalStepName("originalName"))
                     .setMetadata(new CounterMetadata().setKind(Kind.SET.toString())))
-            .setCumulative(false)
+            .setCumulative(true)
             .setStringList(new StringList().setElements(Arrays.asList("ab", "cd")));
 
     assertThat(executionContext.extractMetricUpdates(false), containsInAnyOrder(expected));