This is an automated email from the ASF dual-hosted git repository.

yiguolei pushed a commit to branch branch-1.2-lts
in repository https://gitbox.apache.org/repos/asf/doris.git


The following commit(s) were added to refs/heads/branch-1.2-lts by this push:
     new 75230a40ec [log](fe) add more detail log for master transfer (#17350)
75230a40ec is described below

commit 75230a40ec4a60dc8f6a85429853c5619e476d62
Author: Lei Zhang <27994433+swjtu-zhang...@users.noreply.github.com>
AuthorDate: Thu Mar 2 21:00:53 2023 +0800

    [log](fe) add more detail log for master transfer (#17350)
---
 fe/fe-core/src/main/java/org/apache/doris/catalog/Env.java   | 3 +++
 fe/fe-core/src/main/java/org/apache/doris/ha/MasterInfo.java | 9 +++++++++
 2 files changed, 12 insertions(+)

diff --git a/fe/fe-core/src/main/java/org/apache/doris/catalog/Env.java 
b/fe/fe-core/src/main/java/org/apache/doris/catalog/Env.java
index 362a7b103b..98015e7b4a 100755
--- a/fe/fe-core/src/main/java/org/apache/doris/catalog/Env.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/catalog/Env.java
@@ -1323,6 +1323,7 @@ public class Env {
         this.masterHttpPort = Config.http_port;
         MasterInfo info = new MasterInfo(this.masterIp, this.masterHttpPort, 
this.masterRpcPort);
         editLog.logMasterInfo(info);
+        LOG.info("logMasterInfo:{}", info);
 
         // for master, the 'isReady' is set behind.
         // but we are sure that all metadata is replayed if we get here.
@@ -3617,6 +3618,8 @@ public class Env {
         this.masterIp = info.getIp();
         this.masterHttpPort = info.getHttpPort();
         this.masterRpcPort = info.getRpcPort();
+        LOG.info("setMaster MasterInfo:{}", info);
+
     }
 
     public boolean canRead() {
diff --git a/fe/fe-core/src/main/java/org/apache/doris/ha/MasterInfo.java 
b/fe/fe-core/src/main/java/org/apache/doris/ha/MasterInfo.java
index 343731f036..29fdaf26de 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/ha/MasterInfo.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/ha/MasterInfo.java
@@ -66,6 +66,15 @@ public class MasterInfo implements Writable {
         this.rpcPort = rpcPort;
     }
 
+    @Override
+    public String toString() {
+        StringBuilder sb = new StringBuilder();
+        sb.append("MasterInfo: ip=").append(ip)
+                .append(" httpPort=").append(httpPort)
+                .append(" rpcPort=").append(rpcPort);
+        return sb.toString();
+    }
+
     @Override
     public void write(DataOutput out) throws IOException {
         Text.writeString(out, ip);


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org

Reply via email to