diff --git a/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/HMSExternalTable.java b/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/HMSExternalTable.java index 76f2f6c4b3..8b0fee92ad 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/HMSExternalTable.java +++ b/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/HMSExternalTable.java @@ -543,8 +543,7 @@ public class HMSExternalTable extends ExternalTable implements MTMVRelatedTableI public boolean hasColumnStatistics(String colName) { Map parameters = remoteTable.getParameters(); - return parameters.keySet().stream() - .filter(k -> k.startsWith(SPARK_COL_STATS + colName + ".")).findAny().isPresent(); + return parameters.keySet().stream().anyMatch(k -> k.startsWith(SPARK_COL_STATS + colName + ".")); } public boolean fillColumnStatistics(String colName, Map statsTypes, Map stats) { @@ -556,12 +555,8 @@ public class HMSExternalTable extends ExternalTable implements MTMVRelatedTableI Map parameters = remoteTable.getParameters(); for (StatsType type : statsTypes.keySet()) { String key = SPARK_COL_STATS + colName + MAP_SPARK_STATS_TO_DORIS.getOrDefault(type, "-"); - if (parameters.containsKey(key)) { - stats.put(statsTypes.get(type), parameters.get(key)); - } else { - // should not happen, spark would have all type (except histogram) - stats.put(statsTypes.get(type), "NULL"); - } + // 'NULL' should not happen, spark would have all type (except histogram) + stats.put(statsTypes.get(type), parameters.getOrDefault(key, "NULL")); } return true; }