big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

HDFS-15258. RBF: Mark Router FSCK unstable. (#1934)

Browse Source 
(cherry picked from commit 1695d8d59c)
This commit is contained in:
Akira Ajisaka 2020-04-04 00:13:41 +09:00
parent 215a62e99f
commit d501c6a43d
No known key found for this signature in database
GPG Key ID: C1EDBB9CA400FD50
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RouterFsck.java
View File

@ -33,6 +33,7 @@
import java.util.Map.Entry; import java.util.Map.Entry;
import org.apache.hadoop.classification.InterfaceAudience; 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.resolver.FederationNamenodeServiceState;
import org.apache.hadoop.hdfs.server.federation.store.MembershipStore; import org.apache.hadoop.hdfs.server.federation.store.MembershipStore;
import org.apache.hadoop.hdfs.server.federation.store.StateStoreService; import org.apache.hadoop.hdfs.server.federation.store.StateStoreService;
@ -48,6 +49,7 @@
* Wrapper for the Router to offer the Namenode FSCK. * Wrapper for the Router to offer the Namenode FSCK.
*/ */
@InterfaceAudience.Private @InterfaceAudience.Private
@InterfaceStability.Unstable
public class RouterFsck { public class RouterFsck {
public static final Logger LOG = public static final Logger LOG =
@ -69,6 +71,10 @@ public RouterFsck(Router router, Map<String, String[]> pmap,
public void fsck() { public void fsck() {
final long startTime = Time.monotonicNow(); final long startTime = Time.monotonicNow();
try { 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 " + String msg = "Federated FSCK started by " +
UserGroupInformation.getCurrentUser() + " from " + remoteAddress + UserGroupInformation.getCurrentUser() + " from " + remoteAddress +
" at " + new Date(); " at " + new Date();