flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/ZooKeeperCompletedCheckpointStore.java
/**
	 * Removes a checkpoint from ZooKeeper because of Job shutdown and drops the state.
	 */
Removes a checkpoint from ZooKeeper because of Job shutdown and drops the state.
Removes a checkpoint from ZooKeeper because of Job shutdown and drops the state .
private void removeShutdown(
			final CompletedCheckpoint completedCheckpoint,
			final JobStatus jobStatus) throws Exception {
		if (completedCheckpoint == null) {
			return;
		}
		ZooKeeperStateHandleStore.RemoveCallback<CompletedCheckpoint> removeAction = new ZooKeeperStateHandleStore.RemoveCallback<CompletedCheckpoint>() {
			@Override
			public void apply(@Nullable RetrievableStateHandle<CompletedCheckpoint> value) throws FlinkException {
				try {
					completedCheckpoint.discardOnShutdown(jobStatus);
				} catch (Exception e) {
					throw new FlinkException("Could not discard the completed checkpoint on subsume.", e);
				}
			}
		};
		checkpointsInZooKeeper.releaseAndTryRemove(
			checkpointIdToPath(completedCheckpoint.getCheckpointID()),
			removeAction);
	}
private void removeShutdown ( final CompletedCheckpoint completedCheckpoint , final JobStatus jobStatus ) throws Exception { if ( completedCheckpoint == null ) { return ; } ZooKeeperStateHandleStore . RemoveCallback < CompletedCheckpoint > removeAction = new ZooKeeperStateHandleStore . RemoveCallback < CompletedCheckpoint > ( ) { @ Override public void apply ( @ Nullable RetrievableStateHandle < CompletedCheckpoint > value ) throws FlinkException { try { completedCheckpoint . discardOnShutdown ( jobStatus ) ; } catch ( Exception e ) { throw new FlinkException ( "Could not discard the completed checkpoint on subsume." , e ) ; } } } ; checkpointsInZooKeeper . releaseAndTryRemove ( checkpointIdToPath ( completedCheckpoint . getCheckpointID ( ) ) , removeAction ) ; }
Removes a checkpoint from ZooKeeper because of Job shutdown and drops the state.
Removes a checkpoint from ZooKeeper because of Job shutdown and drops the state .