flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
/**
	 * Discards the given pending checkpoint because of the given cause.
	 *
	 * @param pendingCheckpoint to discard
	 * @param cause for discarding the checkpoint
	 */
Discards the given pending checkpoint because of the given cause.
@param pendingCheckpoint to discard
@param cause for discarding the checkpoint
Discards the given pending checkpoint because of the given cause . @param pendingCheckpoint to discard @param cause for discarding the checkpoint
private void discardCheckpoint(PendingCheckpoint pendingCheckpoint, @Nullable Throwable cause) {
		assert(Thread.holdsLock(lock));
		Preconditions.checkNotNull(pendingCheckpoint);
		final long checkpointId = pendingCheckpoint.getCheckpointId();
		final String reason = (cause != null) ? cause.getMessage() : "";
		LOG.info("Discarding checkpoint {} because: {}", checkpointId, reason);
		pendingCheckpoint.abortDeclined();
		rememberRecentCheckpointId(checkpointId);
		boolean haveMoreRecentPending = false;
		for (PendingCheckpoint p : pendingCheckpoints.values()) {
			if (!p.isDiscarded() && p.getCheckpointId() >= pendingCheckpoint.getCheckpointId()) {
				haveMoreRecentPending = true;
				break;
			}
		}
		if (!haveMoreRecentPending) {
			triggerQueuedRequests();
		}
	}
private void discardCheckpoint ( PendingCheckpoint pendingCheckpoint , @ Nullable Throwable cause ) { assert ( Thread . holdsLock ( lock ) ) ; Preconditions . checkNotNull ( pendingCheckpoint ) ; final long checkpointId = pendingCheckpoint . getCheckpointId ( ) ; final String reason = ( cause != null ) ? cause . getMessage ( ) : "" ; LOG . info ( "Discarding checkpoint {} because: {}" , checkpointId , reason ) ; pendingCheckpoint . abortDeclined ( ) ; rememberRecentCheckpointId ( checkpointId ) ; boolean haveMoreRecentPending = false ; for ( PendingCheckpoint p : pendingCheckpoints . values ( ) ) { if ( ! p . isDiscarded ( ) && p . getCheckpointId ( ) >= pendingCheckpoint . getCheckpointId ( ) ) { haveMoreRecentPending = true ; break ; } } if ( ! haveMoreRecentPending ) { triggerQueuedRequests ( ) ; } }
Discards the given pending checkpoint because of the given cause.
Discards the given pending checkpoint because of the given cause .
// we don't have to schedule another "dissolving" checkpoint any more because the // cancellation barriers take care of breaking downstream alignments // we only need to make sure that suspended queued requests are resumed