PR feedback

apache · Jan 13, 2023 · f8bbc92 · f8bbc92
1 parent 7c6e217
commit f8bbc92
Show file tree

Hide file tree

Showing 2 changed files with 20 additions and 14 deletions.
diff --git a/...e-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/DumpHdfsClusterStatusAction.java b/...e-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/DumpHdfsClusterStatusAction.java
@@ -73,6 +73,6 @@ public void perform() throws Exception {
     }
     // TODO: add more on NN, JNs, and ZK.
     // TODO: Print how long process has been up.
-    LOG.info(sb.toString());
+    getLogger().info(sb.toString());
   }
 }
diff --git a/...e-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RestartActiveNameNodeAction.java b/...e-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/RestartActiveNameNodeAction.java
@@ -17,7 +17,9 @@
  */
 package org.apache.hadoop.hbase.chaos.actions;
 
+import java.util.Collections;
 import java.util.List;
+import java.util.Optional;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.hbase.ServerName;
 import org.apache.hadoop.hbase.zookeeper.RecoverableZooKeeper;
@@ -78,26 +80,30 @@ public void perform() throws Exception {
         final String hadoopHAZkNodePath = ZNodePaths.joinZNode(
           (hadoopHAZkNode != null && hadoopHAZkNode.equals("/")) ? "" : hadoopHAZkNode,
           nameServiceID);
-        final List<String> subChildren = ZKUtil.listChildrenNoWatch(zkw, hadoopHAZkNodePath);
+        final List<String> subChildren =
+          Optional.ofNullable(ZKUtil.listChildrenNoWatch(zkw, hadoopHAZkNodePath))
+            .orElse(Collections.emptyList());
         for (final String eachEntry : subChildren) {
-          if (eachEntry.contains(ACTIVE_NN_LOCK_NAME)) {
-            byte[] data = rzk.getData(ZNodePaths.joinZNode(hadoopHAZkNodePath, ACTIVE_NN_LOCK_NAME),
-              false, null);
-            ActiveNodeInfo proto = ActiveNodeInfo.parseFrom(data);
-            activeNamenode = proto.getHostname();
-            activeNamenodePort = proto.getPort();
+          if (!eachEntry.contains(ACTIVE_NN_LOCK_NAME)) {
+            continue;
           }
+          byte[] data =
+            rzk.getData(ZNodePaths.joinZNode(hadoopHAZkNodePath, ACTIVE_NN_LOCK_NAME), false, null);
+          ActiveNodeInfo proto = ActiveNodeInfo.parseFrom(data);
+          activeNamenode = proto.getHostname();
+          activeNamenodePort = proto.getPort();
         }
       }
     }
 
     if (activeNamenode == null) {
-      throw new Exception("No active Name node found in zookeeper under " + hadoopHAZkNode);
-    } else {
-      getLogger().info("Found Active NameNode host: {}", activeNamenode);
-      final ServerName activeNNHost = ServerName.valueOf(activeNamenode, activeNamenodePort, -1L);
-      getLogger().info("Restarting Active NameNode: {}", activeNamenode);
-      restartNameNode(activeNNHost, this.sleepTime);
+      getLogger().info("No active Name node found in zookeeper under '{}'", hadoopHAZkNode);
+      return;
     }
+
+    getLogger().info("Found Active NameNode host: {}", activeNamenode);
+    final ServerName activeNNHost = ServerName.valueOf(activeNamenode, activeNamenodePort, -1L);
+    getLogger().info("Restarting Active NameNode: {}", activeNamenode);
+    restartNameNode(activeNNHost, this.sleepTime);
   }
 }