From c5f26e25549ba4ba3c16ea228927b7679b37a969 Mon Sep 17 00:00:00 2001 From: zhanghaobo Date: Fri, 11 Oct 2024 14:15:08 +0800 Subject: [PATCH] fix return value of getExistingLocationAsync --- .../hadoop/hdfs/server/federation/router/RouterRpcServer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RouterRpcServer.java b/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RouterRpcServer.java index 9252b96d9800c..54140d77952d1 100644 --- a/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RouterRpcServer.java +++ b/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RouterRpcServer.java @@ -1101,7 +1101,7 @@ private RemoteLocation getExistingLocationAsync(String src, } return null; }); - return asyncReturn(null); + return asyncReturn(RemoteLocation.class); } @Override // ClientProtocol