rkhachatryan commented on a change in pull request #17774:
URL: https://github.com/apache/flink/pull/17774#discussion_r766731596
##########
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistry.java
##########
@@ -269,65 +143,23 @@ public String toString() {
}
}
- /** The result of an attempt to (un)/reference state */
- public static class Result {
-
- /** The (un)registered state handle from the request */
- private final StreamStateHandle reference;
+ SharedStateRegistry NO_OP =
+ new SharedStateRegistry() {
+ @Override
+ public void close() {}
Review comment:
Sure, moved it to `[FLINK-24611] Register shared state on checkpoint
ACK`.
--
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.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
