@Override
	public CompletableFuture<Acknowledge> cancel(Time timeout) {
		executionGraph.cancel();

		return CompletableFuture.completedFuture(Acknowledge.get());
	}
@ Override public CompletableFuture < Acknowledge > cancel ( Time timeout ) { executionGraph . cancel ( ) ; return CompletableFuture . completedFuture ( Acknowledge . get ( ) ) ; }
----------------------------------------------------------------------------------------------