OriginalCompleteBefore	OriginalCompleteAfter	Before	After	Project	Commit	CompilationUnit	LineNos	Names	TemplateVariableToCodeBefore	RelevantImports	TemplateVariableToCodeAfter	isRelevant	isSafe
newKeyedStateStream=getKeyedStateHandles(parallelKeyedStateStream,subtaskKeyGroupIds);	subManagedKeyedState=getManagedKeyedStateHandles(operatorState,keyGroupPartitions.get(subTaskIndex));	newKeyedStateStream=getKeyedStateHandles(parallelKeyedStateStream,subtaskKeyGroupIds)	newKeyedStateStream=getManagedKeyedStateHandles(operatorState,keyGroupPartitions.get(subTaskIndex))	flink	f7980a7e29457753eb3c5b975f3bb4b59d2014f8	org.apache.flink.runtime.checkpoint.StateAssignmentOperation	_1 257 _2 263	_1 newKeyedStateStream _2 subManagedKeyedState	TCIVar newKeyedStateStream		TCIVar newKeyedStateStream	Uses	False