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) | flink | b71154a734ea9f4489dffe1be6761efbb90cff41 | org.apache.flink.streaming.runtime.tasks.InterruptSensitiveRestoreTest | | _1 | keyedStateFromBackend |
---|
_2 | keyedStateFromBackend |
---|
| TCIVar | keyedStateFromBackend |
---|
v0 | keyedStateFromStream |
---|
v1 | operatorStateStream |
---|
v3 | operatorState |
---|
v4 | operatorStateBackend |
---|
| - org.apache.flink.runtime.checkpoint.OperatorSubtaskState
| TCIVar | keyedStateFromBackend |
---|
v0 | keyedStateFromStream |
---|
v1 | operatorStateStream |
---|
v3 | operatorState |
---|
v4 | operatorStateBackend |
---|
| Uses | True |