From 121a589048574c7f745462862d5cccc75632b5b4 Mon Sep 17 00:00:00 2001 From: Danny McCormick Date: Wed, 4 Feb 2026 15:24:24 -0500 Subject: [PATCH 1/2] Fix linting/compilation violation --- .../worker/windmill/state/WindmillTagEncodingV2Test.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillTagEncodingV2Test.java b/runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillTagEncodingV2Test.java index af9ef95410d1..9d7b9d29d4ef 100644 --- a/runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillTagEncodingV2Test.java +++ b/runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillTagEncodingV2Test.java @@ -319,7 +319,13 @@ public void testTimerTag() { new Instant(123), new Instant(456), timeDomain) - : TimerData.of(TIMER_ID, namespace, new Instant(123), new Instant(456), timeDomain); + : TimerData.of( + TIMER_ID, + namespace, + new Instant(123), + new Instant(456), + timeDomain, + TimerData.CausedByDrain.NORMAL); assertEquals(expectedBytes, WindmillTagEncodingV2.instance().timerTag(prefix, timerData)); } } From d57bc5b33d9cbc0419df691f5b0a02b2dced7655 Mon Sep 17 00:00:00 2001 From: Danny Mccormick Date: Wed, 4 Feb 2026 15:46:32 -0500 Subject: [PATCH 2/2] fmt --- .../windmill/state/WindmillTagEncodingV2Test.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillTagEncodingV2Test.java b/runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillTagEncodingV2Test.java index 9d7b9d29d4ef..d06b4e9ccbad 100644 --- a/runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillTagEncodingV2Test.java +++ b/runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillTagEncodingV2Test.java @@ -321,11 +321,11 @@ public void testTimerTag() { timeDomain) : TimerData.of( TIMER_ID, - namespace, - new Instant(123), - new Instant(456), - timeDomain, - TimerData.CausedByDrain.NORMAL); + namespace, + new Instant(123), + new Instant(456), + timeDomain, + TimerData.CausedByDrain.NORMAL); assertEquals(expectedBytes, WindmillTagEncodingV2.instance().timerTag(prefix, timerData)); } }