[
https://issues.apache.org/jira/browse/BEAM-13575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17491393#comment-17491393
]
Beam JIRA Bot commented on BEAM-13575:
--------------------------------------
This issue is assigned but has not received an update in 30 days so it has been
labeled "stale-assigned". If you are still working on the issue, please give an
update and remove the label. If you are no longer working on the issue, please
unassign so someone else may work on it. In 7 days the issue will be
automatically unassigned.
> 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
> Assignee: Kyle Weaver
> Priority: P2
> Labels: flake, stale-assigned
> Time Spent: 40m
> Remaining Estimate: 0h
>
> 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)
