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 950d52753f..10c6e88bd0 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,11 +1323,13 @@ public class Env { // MUST set master ip before starting checkpoint thread. // because checkpoint thread need this info to select non-master FE to push image + this.masterInfo = new MasterInfo(Env.getCurrentEnv().getSelfNode().getIp(), Env.getCurrentEnv().getSelfNode().getHostName(), Config.http_port, Config.rpc_port); editLog.logMasterInfo(masterInfo); + LOG.info("logMasterInfo:{}", masterInfo); this.resourceGroupMgr.init(); @@ -3674,6 +3676,7 @@ public class Env { public void setMaster(MasterInfo info) { this.masterInfo = info; + 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 624d733b2e..4f3276f5b2 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 @@ -86,6 +86,16 @@ public class MasterInfo implements Writable { this.rpcPort = rpcPort; } + @Override + public String toString() { + StringBuilder sb = new StringBuilder(); + sb.append("MasterInfo: ip=").append(ip) + .append(" hostName=").append(hostName) + .append(" httpPort=").append(httpPort) + .append(" rpcPort=").append(rpcPort); + return sb.toString(); + } + @Override public void write(DataOutput out) throws IOException { String json = GsonUtils.GSON.toJson(this);