Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6350#discussion_r202962522
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
---
@@ -457,13 +457,20 @@ public CheckpointTriggerResult triggerCheckpoint(
Execution[] executions = new Execution[tasksToTrigger.length];
for (int i = 0; i < tasksToTrigger.length; i++) {
Execution ee =
tasksToTrigger[i].getCurrentExecutionAttempt();
- if (ee != null && ee.getState() ==
ExecutionState.RUNNING) {
- executions[i] = ee;
- } else {
+ if (ee == null) {
--- End diff --
according to the `ExecutionVertex` docs this branch shouldn't be necessary
at all, but i kept it in to be safe.
---
