[GitHub] [flink] 1996fanrui commented on a diff in pull request #22983: [FLINK-32049][checkpoint] Fix thread-safe bug of channel state executor when some subtasks are closed while other subtasks are s

1996fanrui commented on code in PR #22983: URL: https://github.com/apache/flink/pull/22983#discussion_r1260742080 ## flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestExecutorImpl.java: ## @@ -348,24 +360,29 @@ public void

[GitHub] [flink] 1996fanrui commented on a diff in pull request #22983: [FLINK-32049][checkpoint] Fix thread-safe bug of channel state executor when some subtasks are closed while other subtasks are s

1996fanrui commented on code in PR #22983: URL: https://github.com/apache/flink/pull/22983#discussion_r1260737895 ## flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestExecutorFactoryTest.java: ## @@ -69,4 +72,60 @@ private void