diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java index 11ac3fc760b..0538d384625 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java @@ -95,6 +95,7 @@ import java.util.concurrent.atomic.AtomicLong; import static org.apache.hadoop.hdfs.server.namenode.FSDirStatAndListingOp.*; import static org.apache.hadoop.ha.HAServiceProtocol.HAServiceState.ACTIVE; +import static org.apache.hadoop.ha.HAServiceProtocol.HAServiceState.STANDBY; import static org.apache.hadoop.ha.HAServiceProtocol.HAServiceState.OBSERVER; import org.apache.hadoop.hdfs.protocol.OpenFileEntry; import org.apache.hadoop.hdfs.server.protocol.SlowDiskReports; @@ -1391,7 +1392,8 @@ public class FSNamesystem implements Namesystem, FSNamesystemMBean, /** Stop services required in standby state */ void stopStandbyServices() throws IOException { - LOG.info("Stopping services started for standby state"); + HAServiceState curState = getState() == OBSERVER? OBSERVER : STANDBY; + LOG.info("Stopping services started for {} state", curState); if (standbyCheckpointer != null) { standbyCheckpointer.stop(); }