[GitHub] [flink] zjureel commented on a change in pull request #18007: [FLINK-25085][runtime] Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped

[GitBox]

zjureel commented on a change in pull request #18007:
URL: https://github.com/apache/flink/pull/18007#discussion_r772091393



##########
File path: 
flink-rpc/flink-rpc-core/src/main/java/org/apache/flink/runtime/rpc/FencedRpcEndpoint.java
##########
@@ -56,10 +56,12 @@ protected FencedRpcEndpoint(
         this.fencingToken = fencingToken;
         this.unfencedMainThreadExecutor =
                 new UnfencedMainThreadExecutor((FencedMainThreadExecutable) 
rpcServer);
+
+        MainThreadExecutable mainThreadExecutable =
+                getRpcService().fenceRpcServer(rpcServer, fencingToken);

Review comment:
       @KarmaGYZ It's automatically separated by `mvn spotless:apply`, i think 
it's better keep it like this




-- 
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