TestStream.testFirstElementLate gives wrong answer on FlinkRunner
Open
flink
improvement
P3
runners
- Dominant language
- Java
- Stars
- 8.7k
- Forks
- 4.7k
- Avg merge
- 1d 20h
- Merged PRs (30d)
- 196
Description
https://ci-beam.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_PR/358/testReport/junit/org.apache.beam.sdk.testing/TestStreamTest/testFirstElementLate/
```
Expected: iterable with items [] in any order
but: no match for: "late"
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.testFirstElementLate(TestStreamTest.java:258)
```
Imported from Jira [BEAM-12037](https://issues.apache.org/jira/browse/BEAM-12037). Original Jira may contain additional context.
Reported by: kenn.
Contributor guide
Assessment
This issue has not been assessed yet.