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