rkhachatryan commented on a change in pull request #15200:
URL: https://github.com/apache/flink/pull/15200#discussion_r603197915
##########
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/StateChangelogWriterFactory.java
##########
@@ -30,7 +29,7 @@
public interface StateChangelogWriterFactory<Handle extends
StateChangelogHandle<?>>
extends AutoCloseable {
- StateChangelogWriter<Handle> createWriter(OperatorID operatorID,
KeyGroupRange keyGroupRange);
+ StateChangelogWriter<Handle> createWriter(String operatorID, KeyGroupRange
keyGroupRange);
Review comment:
I'd prefer `OperatorID` type, but it comes in form of `String` here from
`StateBackend.createKeyedStateBackend` which is `PublicEvolving`.
I think changing this `PublicEvolving` API would be overkill.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
