flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionJobVertex.java
/**
	 * Cancels all currently running vertex executions.
	 *
	 * @return A future that is complete once all tasks have canceled.
	 */
Cancels all currently running vertex executions.
@return A future that is complete once all tasks have canceled.
Cancels all currently running vertex executions . @return A future that is complete once all tasks have canceled .
public CompletableFuture<Void> cancelWithFuture() {
		CompletableFuture<ExecutionState>[] futures = Arrays.stream(getTaskVertices())
			.map(ExecutionVertex::cancel)
			.<CompletableFuture<ExecutionState>>toArray(CompletableFuture[]::new);
		return CompletableFuture.allOf(futures);
	}
public CompletableFuture < Void > cancelWithFuture ( ) { CompletableFuture < ExecutionState > [ ] futures = Arrays . stream ( getTaskVertices ( ) ) . map ( ExecutionVertex :: cancel ) . < CompletableFuture < ExecutionState > > toArray ( CompletableFuture [ ] :: new ) ; return CompletableFuture . allOf ( futures ) ; }
Cancels all currently running vertex executions.
Cancels all currently running vertex executions .
// we collect all futures from the task cancellations // return a conjunct future, which is complete once all individual tasks are canceled