fredia commented on code in PR #21050:
URL: https://github.com/apache/flink/pull/21050#discussion_r1015085362
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistryImpl.java:
##
@@ -95,60 +95,78 @@ public StreamStateHandle registerReference(
fredia commented on code in PR #21050:
URL: https://github.com/apache/flink/pull/21050#discussion_r1011089971
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistryImpl.java:
##
@@ -95,60 +95,78 @@ public StreamStateHandle registerReference(
fredia commented on code in PR #21050:
URL: https://github.com/apache/flink/pull/21050#discussion_r1010263764
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistryImpl.java:
##
@@ -95,60 +95,78 @@ public StreamStateHandle registerReference(
fredia commented on code in PR #21050:
URL: https://github.com/apache/flink/pull/21050#discussion_r1002943684
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistryImpl.java:
##
@@ -95,60 +95,78 @@ public StreamStateHandle registerReference(
fredia commented on code in PR #21050:
URL: https://github.com/apache/flink/pull/21050#discussion_r997761529
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistryImpl.java:
##
@@ -95,60 +95,78 @@ public StreamStateHandle registerReference(
fredia commented on code in PR #21050:
URL: https://github.com/apache/flink/pull/21050#discussion_r997761529
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistryImpl.java:
##
@@ -95,60 +95,78 @@ public StreamStateHandle registerReference(
fredia commented on code in PR #21050:
URL: https://github.com/apache/flink/pull/21050#discussion_r996564183
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistryImpl.java:
##
@@ -95,60 +95,78 @@ public StreamStateHandle registerReference(
fredia commented on code in PR #21050:
URL: https://github.com/apache/flink/pull/21050#discussion_r996560465
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistryImpl.java:
##
@@ -95,60 +95,78 @@ public StreamStateHandle registerReference(
fredia commented on code in PR #21050:
URL: https://github.com/apache/flink/pull/21050#discussion_r996560465
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistryImpl.java:
##
@@ -95,60 +95,78 @@ public StreamStateHandle registerReference(