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

[ehancement](profile) Disable profiling for the internal query (#17720)

Browse Source
This commit is contained in:
AKIRA
2023-03-15 10:48:29 +09:00
committed by GitHub
parent 64c2437be5
commit 16a4dc0a85
2 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
fe/fe-core/src/main/java/org/apache/doris/qe/QeProcessorImpl.java
View File

@ -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);
}

1
fe/fe-core/src/main/java/org/apache/doris/statistics/util/StatisticsUtil.java
View File

@ -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());