Kyle Weaver created BEAM-13575:
----------------------------------
Summary: Flink testParDoRequiresStableInput flaky
Key: BEAM-13575
URL: https://issues.apache.org/jira/browse/BEAM-13575
Project: Beam
Issue Type: Bug
Components: runner-flink, test-failures
Reporter: Kyle Weaver
https://ci-beam.apache.org/job/beam_PreCommit_Java_Commit/20253/
org.apache.beam.runners.flink.FlinkRequiresStableInputTest.testParDoRequiresStableInput
java.util.concurrent.ExecutionException:
java.util.concurrent.CompletionException:
org.apache.flink.runtime.checkpoint.CheckpointException: Checkpoint triggering
task Source: Impulse ->
CreatePCollectionOfOneValue/Read(CreateSource)/ParDo(OutputSingleSource)/ParMultiDo(OutputSingleSource)
->
CreatePCollectionOfOneValue/Read(CreateSource)/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper)/Pair
with initial restriction/ParMultiDo(PairWithRestriction) ->
CreatePCollectionOfOneValue/Read(CreateSource)/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper)/Split
restriction/ParMultiDo(SplitRestriction) ->
CreatePCollectionOfOneValue/Read(CreateSource)/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper)/Explode
windows/ParMultiDo(ExplodeWindows) ->
CreatePCollectionOfOneValue/Read(CreateSource)/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper)/Assign
unique key/AddKeys/Map/ParMultiDo(Anonymous) -> ToKeyedWorkItem (1/1) of job
7bbb425ba325dbc1dc4d3cdf1c8b88f9 is not being executed at the moment. Aborting
checkpoint. Failure reason: Not all required tasks are currently running.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
