OriginalCompleteBeforeOriginalCompleteAfterBeforeAfterProjectCommitCompilationUnitLineNosNamesTemplateVariableToCodeBeforeRelevantImportsTemplateVariableToCodeAfterisRelevantisSafe
newKeyedStatesBackend=getKeyedStateHandles(parallelKeyedStatesBackend,subtaskKeyGroupIds);subRawKeyedState=getRawKeyedStateHandles(operatorState,keyGroupPartitions.get(subTaskIndex));newKeyedStatesBackend=getKeyedStateHandles(parallelKeyedStatesBackend,subtaskKeyGroupIds)newKeyedStatesBackend=getRawKeyedStateHandles(operatorState,keyGroupPartitions.get(subTaskIndex))flinkf7980a7e29457753eb3c5b975f3bb4b59d2014f8org.apache.flink.runtime.checkpoint.StateAssignmentOperation
_1256
_2264
_1newKeyedStatesBackend
_2subRawKeyedState
TCIVarnewKeyedStatesBackend
TCIVarnewKeyedStatesBackend
UsesFalse