You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by ay...@apache.org on 2021/04/13 18:04:52 UTC
[hadoop] branch trunk updated: Revert "HDFS-15884. RBF: Remove
unused method getCreateLocation in RouterRpcServer (#2754). Contributed by
tomscut."
This is an automated email from the ASF dual-hosted git repository.
ayushsaxena pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/trunk by this push:
new 7d6f0ca Revert "HDFS-15884. RBF: Remove unused method getCreateLocation in RouterRpcServer (#2754). Contributed by tomscut."
7d6f0ca is described below
commit 7d6f0ca0bd2e189d200ce0f09d05b41aeb857ad4
Author: Ayush Saxena <ay...@apache.org>
AuthorDate: Tue Apr 13 23:28:42 2021 +0530
Revert "HDFS-15884. RBF: Remove unused method getCreateLocation in RouterRpcServer (#2754). Contributed by tomscut."
This reverts commit e565b05c80c731898a54f8c1d358c12090ca5bbf.
The removed method needs to be used in HDFS-15423.
---
.../hdfs/server/federation/router/RouterRpcServer.java | 14 ++++++++++++++
1 file changed, 14 insertions(+)
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 6bf159f..1d0800e 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
@@ -776,6 +776,20 @@ public class RouterRpcServer extends AbstractService implements ClientProtocol,
replication, blockSize, supportedVersions, ecPolicyName, storagePolicy);
}
+
+ /**
+ * Get the location to create a file. It checks if the file already existed
+ * in one of the locations.
+ *
+ * @param src Path of the file to check.
+ * @return The remote location for this file.
+ * @throws IOException If the file has no creation location.
+ */
+ RemoteLocation getCreateLocation(final String src) throws IOException {
+ final List<RemoteLocation> locations = getLocationsForPath(src, true);
+ return getCreateLocation(src, locations);
+ }
+
/**
* Get the location to create a file. It checks if the file already existed
* in one of the locations.
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org