tests passing

datadrivencz · Sep 4, 2024 · 155e274 · 155e274
1 parent 4270e6a
commit 155e274
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/beam/core/src/test/java/cz/o2/proxima/beam/util/state/ExternalStateExpanderTest.java b/beam/core/src/test/java/cz/o2/proxima/beam/util/state/ExternalStateExpanderTest.java
@@ -134,13 +134,13 @@ public void testSimpleExpandWithInitialState() throws CoderException {
         pipeline,
         Create.of(
                 KV.of(
-                    "sum",
+                    "sum/ParMultiDo(Anonymous)",
                     new StateValue(
                         CoderUtils.encodeToByteArray(intCoder, 0),
                         "sum",
                         CoderUtils.encodeToByteArray(longCoder, 2L))),
                 KV.of(
-                    "sum",
+                    "sum/ParMultiDo(Anonymous)",
                     new StateValue(
                         CoderUtils.encodeToByteArray(intCoder, 1),
                         "sum",