This is an automated email from the ASF dual-hosted git repository.
aajisaka pushed a commit to branch branch-3.3
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/branch-3.3 by this push:
new d501c6a HDFS-15258. RBF: Mark Router FSCK unstable. (#1934)
d501c6a is described below
commit d501c6a43d182fec76d0507bd66e785c8c3e3ae5
Author: Akira Ajisaka <[email protected]>
AuthorDate: Sat Apr 4 00:13:41 2020 +0900
HDFS-15258. RBF: Mark Router FSCK unstable. (#1934)
(cherry picked from commit 1695d8d59c4b441448c16c6cee5c83347c4cb87f)
---
.../org/apache/hadoop/hdfs/server/federation/router/RouterFsck.java | 6 ++++++
1 file changed, 6 insertions(+)
diff --git
a/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RouterFsck.java
b/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RouterFsck.java
index 898099c..9a90677 100644
---
a/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RouterFsck.java
+++
b/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RouterFsck.java
@@ -33,6 +33,7 @@ import java.util.Map;
import java.util.Map.Entry;
import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
import
org.apache.hadoop.hdfs.server.federation.resolver.FederationNamenodeServiceState;
import org.apache.hadoop.hdfs.server.federation.store.MembershipStore;
import org.apache.hadoop.hdfs.server.federation.store.StateStoreService;
@@ -48,6 +49,7 @@ import org.slf4j.LoggerFactory;
* Wrapper for the Router to offer the Namenode FSCK.
*/
@InterfaceAudience.Private
[email protected]
public class RouterFsck {
public static final Logger LOG =
@@ -69,6 +71,10 @@ public class RouterFsck {
public void fsck() {
final long startTime = Time.monotonicNow();
try {
+ String warnMsg = "Now FSCK to DFSRouter is unstable feature. " +
+ "There may be incompatible changes between releases.";
+ LOG.warn(warnMsg);
+ out.println(warnMsg);
String msg = "Federated FSCK started by " +
UserGroupInformation.getCurrentUser() + " from " + remoteAddress +
" at " + new Date();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
