Skip to content

Commit b4ffc60

Browse files
committed
remove useless asyncComplete.
1 parent d96666e commit b4ffc60

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/async/RouterAsyncClientProtocol.java

+3-2
Original file line numberDiff line numberDiff line change
@@ -1059,8 +1059,7 @@ public boolean setReplication(String src, short replication)
10591059
*/
10601060
@VisibleForTesting
10611061
@Override
1062-
public boolean isMultiDestDirectory(String src) throws IOException {
1063-
asyncComplete(false);
1062+
public boolean isMultiDestDirectory(String src) {
10641063
asyncTry(() -> {
10651064
if (rpcServer.isPathAll(src)) {
10661065
List<RemoteLocation> locations;
@@ -1077,6 +1076,8 @@ public boolean isMultiDestDirectory(String src) throws IOException {
10771076
return false;
10781077
}
10791078
});
1079+
} else {
1080+
asyncComplete(false);
10801081
}
10811082
});
10821083
asyncCatch((CatchFunction<Object, UnresolvedPathException>) (o, e) -> {

0 commit comments

Comments
 (0)