return new SharedStateRegistryKey(operatorIdentifier + '-' + keyGroupRange,shId); | return new SharedStateRegistryKey(String.valueOf(backendIdentifier) + '-' + keyGroupRange,shId); | operatorIdentifier | String.valueOf(operatorIdentifier) | flink | 8cff17fcc9b4bca6499c26fc2a6318c759cbf251 | org.apache.flink.runtime.state.IncrementalKeyedStateHandle | | _1 | operatorIdentifier |
---|
_2 | backendIdentifier |
---|
| | | | Uses | True |