flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphTestUtils.java
/**
	 * Takes all vertices in the given ExecutionGraph and attempts to move them
	 * from CANCELING to CANCELED.
	 */
Takes all vertices in the given ExecutionGraph and attempts to move them
from CANCELING to CANCELED.
Takes all vertices in the given ExecutionGraph and attempts to move them from CANCELING to CANCELED .
public static void completeCancellingForAllVertices(ExecutionGraph eg) {
		for (ExecutionVertex vertex : eg.getAllExecutionVertices()) {
			vertex.getCurrentExecutionAttempt().cancelingComplete();
		}
	}
public static void completeCancellingForAllVertices ( ExecutionGraph eg ) { for ( ExecutionVertex vertex : eg . getAllExecutionVertices ( ) ) { vertex . getCurrentExecutionAttempt ( ) . cancelingComplete ( ) ; } }
Takes all vertices in the given ExecutionGraph and attempts to move them
 from CANCELING to CANCELED.
Takes all vertices in the given ExecutionGraph and attempts to move them from CANCELING to CANCELED .