From ba0b7a19aa40520213dc25b6c2c9773f013356ea Mon Sep 17 00:00:00 2001 From: rosinha Date: Fri, 31 Jan 2025 16:56:39 +0000 Subject: [PATCH] Fix failing extractMetricUpdatesStringSet --- .../runners/dataflow/worker/BatchModeExecutionContextTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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));