From d501c6a43d182fec76d0507bd66e785c8c3e3ae5 Mon Sep 17 00:00:00 2001 From: Akira Ajisaka Date: Sat, 4 Apr 2020 00:13:41 +0900 Subject: [PATCH] HDFS-15258. RBF: Mark Router FSCK unstable. (#1934) (cherry picked from commit 1695d8d59c4b441448c16c6cee5c83347c4cb87f) --- .../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 898099c908a..9a90677644f 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.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 @@ * Wrapper for the Router to offer the Namenode FSCK. */ @InterfaceAudience.Private +@InterfaceStability.Unstable public class RouterFsck { public static final Logger LOG = @@ -69,6 +71,10 @@ public RouterFsck(Router router, Map pmap, 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();