This is an automated email from the ASF dual-hosted git repository.
dataroaring 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 16a4dc0a85 [ehancement](profile) Disable profiling for the internal
query (#17720)
16a4dc0a85 is described below
commit 16a4dc0a85b315334534d665fcff588854768f6a
Author: AKIRA <[email protected]>
AuthorDate: Wed Mar 15 10:48:29 2023 +0900
[ehancement](profile) Disable profiling for the internal query (#17720)
---
fe/fe-core/src/main/java/org/apache/doris/qe/QeProcessorImpl.java | 3 ++-
.../src/main/java/org/apache/doris/statistics/util/StatisticsUtil.java | 1 +
2 files changed, 3 insertions(+), 1 deletion(-)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/QeProcessorImpl.java
b/fe/fe-core/src/main/java/org/apache/doris/qe/QeProcessorImpl.java
index 81a6bdf4d2..4f3bb54ae3 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/QeProcessorImpl.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/QeProcessorImpl.java
@@ -187,7 +187,8 @@ public final class QeProcessorImpl implements QeProcessor {
}
final TReportExecStatusResult result = new TReportExecStatusResult();
final QueryInfo info = coordinatorMap.get(params.query_id);
- if (info != null && info.connectContext != null &&
info.connectContext.getStatsErrorEstimator() != null) {
+ if (info != null && info.connectContext != null
+ && info.connectContext.getStatsErrorEstimator() != null) {
info.connectContext.getStatsErrorEstimator().updateExactReturnedRows(params);
}
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/statistics/util/StatisticsUtil.java
b/fe/fe-core/src/main/java/org/apache/doris/statistics/util/StatisticsUtil.java
index 8ceabf4897..f8a463b325 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/statistics/util/StatisticsUtil.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/statistics/util/StatisticsUtil.java
@@ -122,6 +122,7 @@ public class StatisticsUtil {
sessionVariable.setMaxExecMemByte(StatisticConstants.STATISTICS_MAX_MEM_PER_QUERY_IN_BYTES);
sessionVariable.setEnableInsertStrict(true);
sessionVariable.parallelExecInstanceNum =
StatisticConstants.STATISTIC_PARALLEL_EXEC_INSTANCE_NUM;
+ sessionVariable.enableProfile = false;
connectContext.setEnv(Env.getCurrentEnv());
connectContext.setDatabase(FeConstants.INTERNAL_DB_NAME);
connectContext.setQualifiedUser(UserIdentity.ROOT.getQualifiedUser());
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
