database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[log](fe) add more detail log for master transfer (#17350) (#17485)

Browse Source
This commit is contained in:
Lei Zhang
2023-04-16 18:35:06 +08:00
committed by GitHub
parent 1cbbc60822
commit e6884a3768
2 changed files with 13 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
fe/fe-core/src/main/java/org/apache/doris/catalog/Env.java
View File

@ -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() {

10
fe/fe-core/src/main/java/org/apache/doris/ha/MasterInfo.java
View File

@ -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);