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

[improve](nereids) check be status when column stats is unknown #19742

Browse Source 
when forbid_unknown_col_stats is open and some column stats is unknown,
we will check the be status by StatisticsUtil.statsTblAvailable(), and report error according to be status.
This commit is contained in:
minghong
2023-05-19 08:53:34 +08:00
committed by GitHub
parent 1e8eb1c756
commit dc8a992bba
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
fe/fe-core/src/main/java/org/apache/doris/nereids/stats/StatsCalculator.java
View File

@ -98,6 +98,7 @@ import org.apache.doris.statistics.Histogram;
import org.apache.doris.statistics.StatisticRange;
import org.apache.doris.statistics.Statistics;
import org.apache.doris.statistics.StatisticsBuilder;
import org.apache.doris.statistics.util.StatisticsUtil;
import com.google.common.collect.Maps;
import org.apache.commons.collections.CollectionUtils;
@ -493,8 +494,13 @@ public class StatsCalculator extends DefaultPlanVisitor<Statistics, Void> {
ColumnStatistic cache = Config.enable_stats ? getColumnStatistic(table, colName) : ColumnStatistic.UNKNOWN;
if (cache == ColumnStatistic.UNKNOWN) {
if (forbidUnknownColStats) {
throw new AnalysisException("column stats for " + colName
+ " is unknown, `set forbid_unknown_col_stats = false` to execute sql with unknown stats");
if (StatisticsUtil.statsTblAvailable()) {
throw new AnalysisException("column stats for " + colName
+ " is unknown,"
+ " `set forbid_unknown_col_stats = false` to execute sql with unknown stats");
} else {
throw new AnalysisException("BE is not available!");
}
}
columnStatisticMap.put(slotReference, cache);
continue;