This is an automated email from the ASF dual-hosted git repository. damccorm pushed a commit to branch users/damccorm/fixLint in repository https://gitbox.apache.org/repos/asf/beam.git
commit 121a589048574c7f745462862d5cccc75632b5b4 Author: Danny McCormick <[email protected]> AuthorDate: Wed Feb 4 15:24:24 2026 -0500 Fix linting/compilation violation --- .../dataflow/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 af9ef95410d..9d7b9d29d4e 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 class WindmillTagEncodingV2Test { 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)); } }
