diff --git a/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RouterClientProtocol.java b/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RouterClientProtocol.java index e52c0c9014e..2c7e90bbdfe 100644 --- a/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RouterClientProtocol.java +++ b/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RouterClientProtocol.java @@ -288,7 +288,7 @@ public class RouterClientProtocol implements ClientProtocol { rpcServer.getLocationsForPath(src, true); RemoteLocation createLocation = null; try { - createLocation = rpcServer.getCreateLocation(src); + createLocation = rpcServer.getCreateLocation(src, locations); return rpcClient.invokeSingle(createLocation, method, HdfsFileStatus.class); } catch (IOException ioe) {