[BugFix] es operator support decimalV3 predicate (backport #43577) (#…

…43915) Signed-off-by: Seaven <[email protected]> Co-authored-by: Seaven <[email protected]>
StarRocks · Apr 12, 2024 · 5df407e · 5df407e
1 parent c06936a
commit 5df407e
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 1 deletion.
diff --git a/be/src/exec/es/es_predicate.cpp b/be/src/exec/es/es_predicate.cpp
@@ -38,6 +38,7 @@
 
 #include <map>
 #include <sstream>
+#include <type_traits>
 #include <utility>
 
 #include "column/column.h"
@@ -50,6 +51,7 @@
 #include "exprs/expr.h"
 #include "exprs/expr_context.h"
 #include "exprs/in_const_predicate.hpp"
+#include "gutil/casts.h"
 #include "runtime/large_int_value.h"
 #include "runtime/runtime_state.h"
 #include "runtime/string_value.h"
@@ -100,6 +102,13 @@ VExtLiteral::VExtLiteral(LogicalType type, ColumnPtr column, const std::string&
         } else {
             _value = "false";
         }
+    } else if (type == TYPE_DECIMAL32 || type == TYPE_DECIMAL64 || type == TYPE_DECIMAL128) {
+        DCHECK(!column->is_null(0));
+        if (column->is_constant()) {
+            _value = down_cast<ConstColumn*>(column.get())->data_column()->debug_item(0);
+        } else {
+            _value = column->debug_item(0);
+        }
     } else {
         _value = _value_to_string(column);
     }

diff --git a/fe/fe-core/src/main/java/com/starrocks/qe/SessionVariable.java b/fe/fe-core/src/main/java/com/starrocks/qe/SessionVariable.java
@@ -1894,7 +1894,7 @@ public SessionVariable setHiveTempStagingDir(String hiveTempStagingDir) {
     @VarAttr(name = CBO_DECIMAL_CAST_STRING_STRICT, flag = VariableMgr.INVISIBLE)
     private boolean cboDecimalCastStringStrict = true;
 
-    @VarAttr(name = CBO_EQ_BASE_TYPE, flag = VariableMgr.INVISIBLE)
+    @VarAttr(name = CBO_EQ_BASE_TYPE)
     private String cboEqBaseType = SessionVariableConstants.DECIMAL;
 
     @VariableMgr.VarAttr(name = ENABLE_RESULT_SINK_ACCUMULATE)