OriginalCompleteBeforeOriginalCompleteAfterBeforeAfterProjectCommitCompilationUnitLineNosNamesTemplateVariableToCodeBeforeRelevantImportsTemplateVariableToCodeAfterisRelevantisSafe
TaskStateHandles taskStateHandles=new TaskStateHandles(operatorState,operatorStateBackend,operatorStateStream,keyedStateFromBackend,keyedStateFromStream);OperatorSubtaskState operatorSubtaskState=new OperatorSubtaskState(operatorState,operatorStateBackend,operatorStateStream,keyedStateFromBackend,keyedStateFromStream);new TaskStateHandles(operatorState,operatorStateBackend,operatorStateStream,keyedStateFromBackend,keyedStateFromStream)new OperatorSubtaskState(operatorState,operatorStateBackend,operatorStateStream,keyedStateFromBackend,keyedStateFromStream)flinkb71154a734ea9f4489dffe1be6761efbb90cff41org.apache.flink.streaming.runtime.tasks.InterruptSensitiveRestoreTest
_1191
_2193
_1keyedStateFromStream
_2keyedStateFromStream
TCIVarkeyedStateFromStream
v1operatorStateStream
v2keyedStateFromBackend
v3operatorState
v4operatorStateBackend
  • org.apache.flink.runtime.checkpoint.OperatorSubtaskState
TCIVarkeyedStateFromStream
v1operatorStateStream
v2keyedStateFromBackend
v3operatorState
v4operatorStateBackend
UsesTrue