This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 802d73f16d [optimization](heartbeart) Rm startuptime from front heart
beart class (#21904)
802d73f16d is described below
commit 802d73f16d74572d72267384ac49ee891c0bb628
Author: herry2038 <[email protected]>
AuthorDate: Wed Jul 19 00:56:36 2023 +0800
[optimization](heartbeart) Rm startuptime from front heart beart class
(#21904)
---------
Co-authored-by: yuxianbing <iloveqaz123>
---
.../src/main/java/org/apache/doris/system/HeartbeatMgr.java | 12 +++---------
1 file changed, 3 insertions(+), 9 deletions(-)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/system/HeartbeatMgr.java
b/fe/fe-core/src/main/java/org/apache/doris/system/HeartbeatMgr.java
index 53427c682e..61942d1e27 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/system/HeartbeatMgr.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/system/HeartbeatMgr.java
@@ -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");
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
