newKeyedStatesBackend=getKeyedStateHandles(parallelKeyedStatesBackend,subtaskKeyGroupIds); | subRawKeyedState=getRawKeyedStateHandles(operatorState,keyGroupPartitions.get(subTaskIndex)); | newKeyedStatesBackend=getKeyedStateHandles(parallelKeyedStatesBackend,subtaskKeyGroupIds) | newKeyedStatesBackend=getRawKeyedStateHandles(operatorState,keyGroupPartitions.get(subTaskIndex)) | flink | f7980a7e29457753eb3c5b975f3bb4b59d2014f8 | org.apache.flink.runtime.checkpoint.StateAssignmentOperation | | _1 | newKeyedStatesBackend |
---|
_2 | subRawKeyedState |
---|
| TCIVar | newKeyedStatesBackend |
---|
| | TCIVar | newKeyedStatesBackend |
---|
| Uses | False |