OriginalCompleteBefore	OriginalCompleteAfter	Before	After	Project	Commit	CompilationUnit	LineNos	Names	TemplateVariableToCodeBefore	RelevantImports	TemplateVariableToCodeAfter	isRelevant	isSafe
executorService.execute(new AsyncCheckpointRunnable(operatorSnapshotsInProgress,checkpointMetaData,checkpointMetrics,startAsyncPartNano,taskName,closeableRegistry,env,asyncExceptionHandler));	executorService.execute(new AsyncCheckpointRunnable(snapshotFutures,metadata,metrics,System.nanoTime(),taskName,closeableRegistry,env,asyncExceptionHandler));	new AsyncCheckpointRunnable(operatorSnapshotsInProgress,checkpointMetaData,checkpointMetrics,startAsyncPartNano,taskName,closeableRegistry,env,asyncExceptionHandler)	new AsyncCheckpointRunnable(operatorSnapshotsInProgress,metadata,metrics,System.nanoTime(),taskName,closeableRegistry,env,asyncExceptionHandler)	flink	6e296ad3f30c5bab51eccbfa005b041f4a1184dc	org.apache.flink.streaming.runtime.tasks.SubtaskCheckpointCoordinatorImpl	_1 146 _2 184	_1 operatorSnapshotsInProgress _2 snapshotFutures	TCIVar operatorSnapshotsInProgress v0 env v1 asyncExceptionHandler v2 taskName v3 closeableRegistry		TCIVar operatorSnapshotsInProgress v0 env v1 asyncExceptionHandler v2 taskName v3 closeableRegistry	Uses	False