From 7ae65a2eef7911db5cd4c889031db72db0fa0382 Mon Sep 17 00:00:00 2001 From: Danny McCormick Date: Fri, 13 Nov 2026 06:32:40 +0000 Subject: [PATCH 1/2] Run testAfterProcessingTimeContinuationTriggerUsingState serially with 2s watermark hold --- .../java/org/apache/beam/sdk/transforms/GroupByKeyTest.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/GroupByKeyTest.java b/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/GroupByKeyTest.java index 13af0c4b356f..c58f6c3966b3 100644 --- a/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/GroupByKeyTest.java +++ b/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/GroupByKeyTest.java @@ -241,6 +241,7 @@ public void testAfterProcessingTimeContinuationTriggerEarly() throws Exception { * suite. */ @Test + @BeamParallelJunit4Runner.SerialTest @Category({ ValidatesRunner.class, UsesTimersInParDo.class, @@ -249,7 +250,7 @@ public void testAfterProcessingTimeContinuationTriggerEarly() throws Exception { }) public void testAfterProcessingTimeContinuationTriggerUsingState() throws Exception { final long triggerMillis = 1; - final long waitMillis = 500; + final long waitMillis = 2000; PCollection triggeredSums = p.apply( From 1296592ad5de676d17211ecc0e5b19c0b5a8a7b6 Mon Sep 17 00:00:00 2001 From: Danny McCormick Date: Fri, 13 Nov 2026 07:44:46 +0000 Subject: [PATCH 2/2] Update Javadoc comment for waitMillis in GroupByKeyTest --- .../java/org/apache/beam/sdk/transforms/GroupByKeyTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/GroupByKeyTest.java b/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/GroupByKeyTest.java index c58f6c3966b3..db8127f473ce 100644 --- a/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/GroupByKeyTest.java +++ b/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/GroupByKeyTest.java @@ -237,8 +237,8 @@ public void testAfterProcessingTimeContinuationTriggerEarly() throws Exception { * many runners do not support it. * *

Since a delay in processing time is fundamental to this test, it unfortunately must have a - * real-time sleep. Currently the sleep is sub-second so it is acceptable delay for a unit test - * suite. + * real-time sleep. Currently the sleep is a couple of seconds so it is an acceptable delay for + * a unit test suite. */ @Test @BeamParallelJunit4Runner.SerialTest