Skip to content

Commit

Permalink
add comment to code
Browse files Browse the repository at this point in the history
  • Loading branch information
EricJoy2048 committed Dec 23, 2023
1 parent ca47855 commit 499f464
Showing 1 changed file with 6 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -231,6 +231,12 @@ private PipelineStatus getPipelineEndState() {
errorByPhysicalVertex.compareAndSet(
null, checkpointCoordinatorState.getThrowableMsg());
}

// Because the pipeline state must update by tasks, If the pipeline can not get enough
// slot,
// the pipeline state will turn to Failing and then cancel all tasks in this pipeline.
// Because the tasks never run, so the tasks will complete with CANCELED. But the actual
// status of the pipeline should be FAILED
if (getPipelineState().equals(PipelineStatus.FAILING)) {
pipelineStatus = PipelineStatus.FAILED;
}
Expand Down

0 comments on commit 499f464

Please sign in to comment.