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

[optimization](heartbeart) Rm startuptime from front heart beart class (#21904)

Browse Source 
---------

Co-authored-by: yuxianbing <iloveqaz123>
This commit is contained in:
herry2038
2023-07-19 00:56:36 +08:00
committed by GitHub
parent 4171309b9b
commit 802d73f16d
1 changed files with 3 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
fe/fe-core/src/main/java/org/apache/doris/system/HeartbeatMgr.java
View File

@ -113,7 +113,7 @@ public class HeartbeatMgr extends MasterDaemon {
for (Frontend frontend : frontends) {
FrontendHeartbeatHandler handler = new FrontendHeartbeatHandler(frontend,
Env.getCurrentEnv().getClusterId(),
Env.getCurrentEnv().getToken(), ExecuteEnv.getInstance().getStartupTime());
Env.getCurrentEnv().getToken());
hbResponses.add(executor.submit(handler));
}
@ -292,13 +292,6 @@ public class HeartbeatMgr extends MasterDaemon {
this.token = token;
}
public FrontendHeartbeatHandler(Frontend fe, int clusterId, String token, long callerFeStartTime) {
this.fe = fe;
this.clusterId = clusterId;
this.token = token;
this.callerFeStartTime = callerFeStartTime;
}
@Override
public HeartbeatResponse call() {
HostInfo selfNode = Env.getCurrentEnv().getSelfNode();
@ -307,7 +300,8 @@ public class HeartbeatMgr extends MasterDaemon {
if (Env.getCurrentEnv().isReady()) {
return new FrontendHbResponse(fe.getNodeName(), Config.query_port, Config.rpc_port,
Env.getCurrentEnv().getMaxJournalId(), System.currentTimeMillis(),
Version.DORIS_BUILD_VERSION + "-" + Version.DORIS_BUILD_SHORT_HASH, callerFeStartTime);
Version.DORIS_BUILD_VERSION + "-" + Version.DORIS_BUILD_SHORT_HASH,
ExecuteEnv.getInstance().getStartupTime());
} else {
return new FrontendHbResponse(fe.getNodeName(), "not ready");
}