You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by da...@apache.org on 2026/02/04 20:24:35 UTC
(beam) 01/01: Fix linting/compilation violation
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 <da...@google.com>
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));
}
}