This is an automated email from the ASF dual-hosted git repository.
morningman 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 b3859e1e1a [ehancement](fe) Remove unnecessary kill in
AutoCloseConnectContext (#14606)
b3859e1e1a is described below
commit b3859e1e1acd7424e1303452fe73330d1bb71726
Author: Kikyou1997 <[email protected]>
AuthorDate: Sat Nov 26 23:54:33 2022 +0800
[ehancement](fe) Remove unnecessary kill in AutoCloseConnectContext (#14606)
The invocation in ConnectContext.kill in AutoCloseConnectContext is
redundant and caused too many useless logs
---
.../src/main/java/org/apache/doris/qe/AutoCloseConnectContext.java | 1 -
fe/fe-core/src/main/java/org/apache/doris/statistics/AnalysisJob.java | 4 ----
2 files changed, 5 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/qe/AutoCloseConnectContext.java
b/fe/fe-core/src/main/java/org/apache/doris/qe/AutoCloseConnectContext.java
index f0019876e5..fe17a25dec 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/AutoCloseConnectContext.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/AutoCloseConnectContext.java
@@ -28,7 +28,6 @@ public class AutoCloseConnectContext implements AutoCloseable
{
@Override
public void close() {
- connectContext.kill(false);
ConnectContext.remove();
}
}
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/statistics/AnalysisJob.java
b/fe/fe-core/src/main/java/org/apache/doris/statistics/AnalysisJob.java
index 3ba55112c6..06fb36e644 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/statistics/AnalysisJob.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/statistics/AnalysisJob.java
@@ -26,7 +26,6 @@ import org.apache.doris.catalog.TableIf;
import org.apache.doris.common.FeConstants;
import org.apache.doris.datasource.CatalogIf;
import org.apache.doris.qe.AutoCloseConnectContext;
-import org.apache.doris.qe.ConnectContext;
import org.apache.doris.qe.StmtExecutor;
import org.apache.doris.statistics.AnalysisJobInfo.JobState;
import org.apache.doris.statistics.util.StatisticsUtil;
@@ -182,10 +181,7 @@ public class AnalysisJob {
this.stmtExecutor = new StmtExecutor(r.connectContext, sql);
this.stmtExecutor.execute();
Env.getCurrentEnv().getStatisticsCache().refreshSync(tbl.getId(),
col.getName());
- } finally {
- ConnectContext.remove();
}
-
}
public int getLastExecTime() {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
