[Bug]: beam_PostCommit_Java_ValidatesRunner_Flink is flakes in org.apache.beam.sdk.transforms.GroupByKeyTest$BasicTests.testAfterProcessingTimeContinuationTriggerUsingState

[jrmccluskey]

What happened?

org.apache.beam.sdk.transforms.GroupByKeyTest > org.apache.beam.sdk.transforms.GroupByKeyTest$BasicTests.testAfterProcessingTimeContinuationTriggerUsingState tests is flaky in the Java Flink ValidatesRunner PosCommit suite.

https://ci-beam.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink/lastCompletedBuild/testReport/org.apache.beam.sdk.transforms/GroupByKeyTest$BasicTests/testAfterProcessingTimeContinuationTriggerUsingState/

Issue Priority

Priority: 1

Issue Component

Component: test-failures

[kennknowles]

Not failing today. It does have some flakes, but not this one from what I can see.

[kennknowles]

Wait, I read it wrong. This is exactly the flake.

[TheNeuralBit]

org.apache.beam.sdk.transforms.ParDoLifecycleTest.testTeardownCalledAfterExceptionInStartBundleStateful is tracked in #21266

Maybe this should just track the GroupByKey one? It does look quite flaky:

[TheNeuralBit]

Updated the description so this just tracks the GroupByKeyTest failure. Let's use #21266 to track the ParDoLifecycleTest flake

[apilloud]

This is the top flaky test in the suite. Recent failures:
https://ci-beam.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink/10960/testReport/org.apache.beam.sdk.transforms/GroupByKeyTest$BasicTests/testAfterProcessingTimeContinuationTriggerUsingState/
https://ci-beam.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink/10961/testReport/org.apache.beam.sdk.transforms/GroupByKeyTest$BasicTests/testAfterProcessingTimeContinuationTriggerUsingState/

java.lang.AssertionError: Second Triggered sum/Values/Values/Map/ParMultiDo(Anonymous).output: 
Expected: iterable with items [<42>] in any order
     but: no match for: <84>
	at org.apache.beam.sdk.testing.PAssert$PAssertionSite.capture(PAssert.java:175)
	at org.apache.beam.sdk.testing.PAssert.that(PAssert.java:460)
	at org.apache.beam.sdk.testing.PAssert.that(PAssert.java:452)
	at org.apache.beam.sdk.transforms.GroupByKeyTest$BasicTests.testAfterProcessingTimeContinuationTriggerUsingState(GroupByKeyTest.java:302)

[apilloud]

As much as I want to work on this, that hasn't happened in the last two weeks and I don't see it happening this year so I'm going to unassign it.

[liferoad]

2024-11-19T11:29:14.9513289Z > Task :runners:flink:1.19:validatesRunnerStreaming
2024-11-19T11:30:19.9507467Z 
2024-11-19T11:30:19.9510128Z org.apache.beam.sdk.transforms.GroupByKeyTest > org.apache.beam.sdk.transforms.GroupByKeyTest$BasicTests.testAfterProcessingTimeContinuationTriggerUsingState FAILED
2024-11-19T11:30:19.9512352Z     java.lang.AssertionError at GroupByKeyTest.java:302
2024-11-19T11:30:19.9513761Z         Caused by: java.lang.AssertionError at MatcherAssert.java:18

[liferoad]

https://github.com/apache/beam/actions/workflows/beam_PostCommit_Java_ValidatesRunner_Flink.yml is usually green.