From 3d692c093622581422755592d22571ddfb4814c8 Mon Sep 17 00:00:00 2001
From: jianghuazhu <740087514@qq.com>
Date: Fri, 12 Nov 2021 09:52:02 +0800
Subject: [PATCH] HDFS-16305.Record the remote NameNode address when the
 rolling log is triggered. (#3629)

---
 .../apache/hadoop/hdfs/server/namenode/ha/EditLogTailer.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/ha/EditLogTailer.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/ha/EditLogTailer.java
index 4a5bd0f7ecb..ec1169b85a8 100644
--- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/ha/EditLogTailer.java
+++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/ha/EditLogTailer.java
@@ -413,6 +413,8 @@ Callable<Void> getNameNodeProxy() {
     return new MultipleNameNodeProxy<Void>() {
       @Override
       protected Void doWork() throws IOException {
+        LOG.info("Triggering log rolling to the remote NameNode, " +
+            "active NameNode = {}", currentNN.getIpcAddress());
         cachedActiveProxy.rollEditLog();
         return null;
       }
@@ -424,7 +426,6 @@ protected Void doWork() throws IOException {
    */
   @VisibleForTesting
   void triggerActiveLogRoll() {
-    LOG.info("Triggering log roll on remote NameNode");
     Future<Void> future = null;
     try {
       future = rollEditsRpcExecutor.submit(getNameNodeProxy());