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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
