This is an automated email from the ASF dual-hosted git repository.
lijibing pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new 08344df8e1c Fix alter column stats without min max value deserialize
failure. (#33406) (#33661)
08344df8e1c is described below
commit 08344df8e1cae734dd592795b77848386480e899
Author: Jibing-Li <[email protected]>
AuthorDate: Mon Apr 15 22:23:22 2024 +0800
Fix alter column stats without min max value deserialize failure. (#33406)
(#33661)
---
.../main/java/org/apache/doris/statistics/StatisticsRepository.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/statistics/StatisticsRepository.java
b/fe/fe-core/src/main/java/org/apache/doris/statistics/StatisticsRepository.java
index 75b827ecd9d..c1aacaba140 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/statistics/StatisticsRepository.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/statistics/StatisticsRepository.java
@@ -76,7 +76,7 @@ public class StatisticsRepository {
private static final String INSERT_INTO_COLUMN_STATISTICS = "INSERT INTO "
+ FULL_QUALIFIED_COLUMN_STATISTICS_NAME + " VALUES('${id}',
${catalogId}, ${dbId}, ${tblId}, '${idxId}',"
- + "'${colId}', ${partId}, ${count}, ${ndv}, ${nullCount},
'${min}', '${max}', ${dataSize}, NOW())";
+ + "'${colId}', ${partId}, ${count}, ${ndv}, ${nullCount}, ${min},
${max}, ${dataSize}, NOW())";
private static final String DROP_TABLE_STATISTICS_TEMPLATE = "DELETE FROM
" + FeConstants.INTERNAL_DB_NAME
+ "." + "${tblName}" + " WHERE ${condition}";
@@ -307,8 +307,8 @@ public class StatisticsRepository {
params.put("count", String.valueOf(columnStatistic.count));
params.put("ndv", String.valueOf(columnStatistic.ndv));
params.put("nullCount", String.valueOf(columnStatistic.numNulls));
- params.put("min", StatisticsUtil.escapeSQL(min));
- params.put("max", StatisticsUtil.escapeSQL(max));
+ params.put("min", min == null ? "NULL" : "'" +
StatisticsUtil.escapeSQL(min) + "'");
+ params.put("max", max == null ? "NULL" : "'" +
StatisticsUtil.escapeSQL(max) + "'");
params.put("dataSize", String.valueOf(columnStatistic.dataSize));
if (partitionIds.isEmpty()) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
