[fix](iceberg) fix error when query iceberg table using date predicate (

#32194)
apache · Mar 15, 2024 · c85af1b · c85af1b
1 parent 0dc0810
commit c85af1b
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/DateLiteral.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/DateLiteral.java
@@ -683,6 +683,10 @@ public boolean isDateType() {
         return this.type.isDate() || this.type.isDateV2();
     }
 
+    public boolean isDateTimeType() {
+        return this.type.isDatetime() || this.type.isDatetimeV2();
+    }
+
     @Override
     public String getStringValue() {
         char[] dateTimeChars = new char[26]; // Enough to hold "YYYY-MM-DD HH:MM:SS.mmmmmm"

diff --git a/fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/IcebergUtils.java b/fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/IcebergUtils.java
@@ -229,7 +229,7 @@ private static Object extractDorisLiteral(Expr expr) {
             return boolLiteral.getValue();
         } else if (expr instanceof DateLiteral) {
             DateLiteral dateLiteral = (DateLiteral) expr;
-            if (dateLiteral.isDateType()) {
+            if (dateLiteral.isDateType() || dateLiteral.isDateTimeType()) {
                 return dateLiteral.getStringValue();
             } else {
                 return dateLiteral.unixTimestamp(TimeUtils.getTimeZone()) * MILLIS_TO_NANO_TIME;