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

[Fix](executor) Fix insert select not close coordinator #32571

Browse Source
This commit is contained in:
wangbo
2024-03-21 13:56:04 +08:00
committed by yiguolei
parent 844dd8b2ce
commit 886aabda31
2 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/insert/AbstractInsertExecutor.java
View File

@ -172,6 +172,7 @@ public abstract class AbstractInsertExecutor {
onFail(t);
return;
} finally {
coordinator.close();
executor.updateProfile(true);
QeProcessorImpl.INSTANCE.unregisterQuery(ctx.queryId());
}

6
fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java
View File

@ -634,7 +634,11 @@ public class Coordinator implements CoordInterface {
@Override
public void close() {
if (queryQueue != null && queueToken != null) {
queryQueue.returnToken(queueToken);
try {
queryQueue.returnToken(queueToken);
} catch (Throwable t) {
LOG.error("error happens when coordinator close ", t);
}
}
}