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 subsumed checkpoint from ZooKeeper and drops the state.
	 */
Removes a subsumed checkpoint from ZooKeeper and drops the state.
Removes a subsumed checkpoint from ZooKeeper and drops the state .
private void removeSubsumed(
		final CompletedCheckpoint completedCheckpoint) throws Exception {
		if (completedCheckpoint == null) {
			return;
		}
		ZooKeeperStateHandleStore.RemoveCallback<CompletedCheckpoint> action =
			new ZooKeeperStateHandleStore.RemoveCallback<CompletedCheckpoint>() {
				@Override
				public void apply(@Nullable RetrievableStateHandle<CompletedCheckpoint> value) throws FlinkException {
					if (value != null) {
						try {
							completedCheckpoint.discardOnSubsume();
						} catch (Exception e) {
							throw new FlinkException("Could not discard the completed checkpoint on subsume.", e);
						}
					}
				}
			};
		checkpointsInZooKeeper.releaseAndTryRemove(
			checkpointIdToPath(completedCheckpoint.getCheckpointID()),
			action);
	}
private void removeSubsumed ( final CompletedCheckpoint completedCheckpoint ) throws Exception { if ( completedCheckpoint == null ) { return ; } ZooKeeperStateHandleStore . RemoveCallback < CompletedCheckpoint > action = new ZooKeeperStateHandleStore . RemoveCallback < CompletedCheckpoint > ( ) { @ Override public void apply ( @ Nullable RetrievableStateHandle < CompletedCheckpoint > value ) throws FlinkException { if ( value != null ) { try { completedCheckpoint . discardOnSubsume ( ) ; } catch ( Exception e ) { throw new FlinkException ( "Could not discard the completed checkpoint on subsume." , e ) ; } } } } ; checkpointsInZooKeeper . releaseAndTryRemove ( checkpointIdToPath ( completedCheckpoint . getCheckpointID ( ) ) , action ) ; }
Removes a subsumed checkpoint from ZooKeeper and drops the state.
Removes a subsumed checkpoint from ZooKeeper and drops the state .