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
_1190
_2192
_1keyedStateFromBackend
_2keyedStateFromBackend
TCIVarkeyedStateFromBackend
v0keyedStateFromStream
v1operatorStateStream
v3operatorState
v4operatorStateBackend
  • org.apache.flink.runtime.checkpoint.OperatorSubtaskState
TCIVarkeyedStateFromBackend
v0keyedStateFromStream
v1operatorStateStream
v3operatorState
v4operatorStateBackend
UsesTrue