docs: private void cleanRestoredHandles() throws Exception {
  		synchronized (pendingCheckpoints) {
  
  			Iterator<PendingCheckpoint> pendingCheckpointIt = pendingCheckpoints.iterator();
  			while (pendingCheckpointIt.hasNext()) {
  				PendingCheckpoint pendingCheckpoint = pendingCheckpointIt.next();
  
  				if (committer.isCheckpointCommitted(pendingCheckpoint.subtaskId, pendingCheckpoint.checkpointId)) {
  					pendingCheckpoint.stateHandle.discardState();
  					pendingCheckpointIt.remove();
  				}
  			}
  		}
  	}