[GitHub] [flink] 1996fanrui commented on a diff in pull request #20137: Just for CI

1996fanrui commented on code in PR #20137: URL: https://github.com/apache/flink/pull/20137#discussion_r1032795523 ## flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestExecutorImpl.java: ## @@ -125,11 +162,72 @@ public void start()

[GitHub] [flink] 1996fanrui commented on a diff in pull request #20137: Just for CI

1996fanrui commented on code in PR #20137: URL: https://github.com/apache/flink/pull/20137#discussion_r1032794990 ## flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestExecutorImpl.java: ## @@ -51,27 +64,46 @@ class