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

[fix](executor) Fe publish topic info tcp leak (#29739)

Browse Source 
* [fix](executor) Fe publish topic info tcp leak

* enhancement
This commit is contained in:
HB
2024-01-09 23:31:20 +08:00
committed by yiguolei
parent 7287c0ca15
commit ff7f09fe1f
1 changed files with 15 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
fe/fe-core/src/main/java/org/apache/doris/common/publish/TopicPublisherThread.java
View File

@ -103,16 +103,29 @@ public class TopicPublisherThread extends MasterDaemon {
@Override
public void run() {
long beginTime = System.currentTimeMillis();
BackendService.Client client = null;
TNetworkAddress address = null;
boolean ok = false;
try {
TNetworkAddress addr = new TNetworkAddress(be.getHost(), be.getBePort());
BackendService.Client client = ClientPool.backendPool.borrowObject(addr);
address = new TNetworkAddress(be.getHost(), be.getBePort());
client = ClientPool.backendPool.borrowObject(address);
client.publishTopicInfo(request);
ok = true;
LOG.info("publish topic info to be {} success, time cost={} ms",
be.getHost(), (System.currentTimeMillis() - beginTime));
} catch (Exception e) {
LOG.warn("publish topic info to be {} error happens: , time cost={} ms",
be.getHost(), (System.currentTimeMillis() - beginTime), e);
} finally {
try {
if (ok) {
ClientPool.backendPool.returnObject(address, client);
} else {
ClientPool.backendPool.invalidateObject(address, client);
}
} catch (Throwable e) {
LOG.warn("recycle topic publish client failed. related backend[{}]", be.getHost(), e);
}
handler.onResponse(be);
}
}