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 aa...@apache.org on 2020/04/03 15:14:14 UTC
[hadoop] branch trunk updated: HDFS-15258. RBF: Mark Router FSCK
unstable. (#1934)
This is an automated email from the ASF dual-hosted git repository.
aajisaka 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 1695d8d HDFS-15258. RBF: Mark Router FSCK unstable. (#1934)
1695d8d is described below
commit 1695d8d59c4b441448c16c6cee5c83347c4cb87f
Author: Akira Ajisaka <aa...@apache.org>
AuthorDate: Sat Apr 4 00:13:41 2020 +0900
HDFS-15258. RBF: Mark Router FSCK unstable. (#1934)
---
.../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
+@InterfaceStability.Unstable
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: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org