(flink) branch master updated: [hotfix] Avoid copy set in PekkoRpcService (#26372)

[fanrui]

This is an automated email from the ASF dual-hosted git repository.

fanrui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 0d86f549bc3 [hotfix] Avoid copy set in PekkoRpcService (#26372)
0d86f549bc3 is described below

commit 0d86f549bc3ed835f13c22262adbddebea6888c0
Author: Jiaan Geng <belie...@163.com>
AuthorDate: Mon Apr 7 15:36:52 2025 +0800

    [hotfix] Avoid copy set in PekkoRpcService (#26372)
---
 .../java/org/apache/flink/runtime/rpc/pekko/PekkoRpcService.java     | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git 
a/flink-rpc/flink-rpc-akka/src/main/java/org/apache/flink/runtime/rpc/pekko/PekkoRpcService.java
 
b/flink-rpc/flink-rpc-akka/src/main/java/org/apache/flink/runtime/rpc/pekko/PekkoRpcService.java
index ab8bee41822..dc76beabdee 100644
--- 
a/flink-rpc/flink-rpc-akka/src/main/java/org/apache/flink/runtime/rpc/pekko/PekkoRpcService.java
+++ 
b/flink-rpc/flink-rpc-akka/src/main/java/org/apache/flink/runtime/rpc/pekko/PekkoRpcService.java
@@ -60,7 +60,6 @@ import java.lang.reflect.InvocationHandler;
 import java.lang.reflect.Proxy;
 import java.util.ArrayList;
 import java.util.Collection;
-import java.util.HashSet;
 import java.util.Map;
 import java.util.Set;
 import java.util.concurrent.CompletableFuture;
@@ -284,8 +283,8 @@ public class PekkoRpcService implements RpcService {
             hostname = host.get();
         }
 
-        Set<Class<?>> implementedRpcGateways =
-                new 
HashSet<>(RpcUtils.extractImplementedRpcGateways(rpcEndpoint.getClass()));
+        Set<Class<? extends RpcGateway>> implementedRpcGateways =
+                RpcUtils.extractImplementedRpcGateways(rpcEndpoint.getClass());
 
         implementedRpcGateways.add(RpcServer.class);
         implementedRpcGateways.add(PekkoBasedEndpoint.class);