[
https://issues.apache.org/jira/browse/BEAM-11141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17221796#comment-17221796
] Boyuan Zhang commented on BEAM-11141: ------------------------------------- The problem is caused by the split contract we are using for both runner issued split and sdf initiated checkpoint. It's not related to flink runner. > SplittableDoFnTest.testPairWithIndexWindowedTimestamped fails on Portable > Flink in both batch and streaming > ----------------------------------------------------------------------------------------------------------- > > Key: BEAM-11141 > URL: https://issues.apache.org/jira/browse/BEAM-11141 > Project: Beam > Issue Type: Bug > Components: runner-flink > Reporter: Boyuan Zhang > Priority: P2 > > The test fails on wrong results: > * batch: > https://ci-beam.apache.org/job/beam_PostCommit_Java_PVR_Flink_Batch_PR/186/testReport/junit/org.apache.beam.sdk.transforms/SplittableDoFnTest/testPairWithIndexWindowedTimestampedBounded/beam.apache.org/job/beam_PostCommit_Java_PVR_Flink_Batch_PR/186/ > * streaming: > https://ci-beam.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming_PR/249/testReport/junit/org.apache.beam.sdk.transforms/SplittableDoFnTest/testPairWithIndexWindowedTimestampedUnbounded/ > from > https://ci-beam.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming_PR/249/ -- This message was sent by Atlassian Jira (v8.3.4#803005)
