[BEAM-12036] TestStream.testLateDataAccumulating gives wrong answer on SamzaRunner

• Type: Improvement
• Status: Open
• Priority: P3
• Resolution: Unresolved
• Component/s: runner-samza
• Assignee: Unassigned
• Reporter: Kenneth Knowles
• Created: 23/Mar/21 18:13
• Updated: 04/Jun/22 19:54

Description

https://ci-beam.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Samza_PR/105/testReport/junit/org.apache.beam.sdk.testing/TestStreamTest/testLateDataAccumulating/

java.lang.AssertionError: Combine.globally(Count)/Values/Values/Map/ParMultiDo(Anonymous).output: 
Expected: (a value equal to or greater than <3L> and a value less than or equal to <5L>)
     but: a value equal to or greater than <3L> <2L> was less than <3L>
	at org.apache.beam.sdk.testing.PAssert$PAssertionSite.capture(PAssert.java:174)
	at org.apache.beam.sdk.testing.PAssert.that(PAssert.java:416)
	at org.apache.beam.sdk.testing.PAssert.that(PAssert.java:408)
	at org.apache.beam.sdk.testing.TestStreamTest.testLateDataAccumulating(TestStreamTest.java:131)

Issue Links

• is cloned by: BEAM-12038 TestStream.testLateDataAccumulating gives wrong answer on FlinkRunner