You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "Boyuan Zhang (Jira)" <ji...@apache.org> on 2020/10/27 21:59:00 UTC
[jira] [Commented] (BEAM-11141)
SplittableDoFnTest.testPairWithIndexWindowedTimestamped fails on Portable
Flink in both batch and streaming
[ 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)