| 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 |