update

zhangstar333 · Jan 11, 2024 · 8f76281 · 8f76281
1 parent a6c84e5
commit 8f76281
Showing 1 changed file with 3 additions and 17 deletions.
diff --git a/be/src/vec/exprs/vruntimefilter_wrapper.cpp b/be/src/vec/exprs/vruntimefilter_wrapper.cpp
@@ -84,23 +84,9 @@ Status VRuntimeFilterWrapper::execute(VExprContext* context, Block* block, int*
         uint8_t* data = nullptr;
         const ColumnWithTypeAndName& result_column = block->get_by_position(*result_column_id);
         if (is_column_const(*result_column.column)) {
-            auto const_data_column =
-                    static_cast<const ColumnConst&>(*result_column.column).get_data_column_ptr();
-            if (const auto* nullable = check_and_get_column<ColumnNullable>(*const_data_column)) {
-                const auto& nested_column_data =
-                        static_cast<const ColumnVector<UInt8>&>(*nullable->get_nested_column_ptr())
-                                .get_data();
-                const auto& null_map_data = static_cast<const ColumnVector<UInt8>&>(
-                                                    *nullable->get_null_map_column_ptr())
-                                                    .get_data();
-                if (nested_column_data[0] == 0 || null_map_data[0] == 1) {
-                    _filtered_rows += block->rows();
-                }
-            } else if (const auto* res_col =
-                               check_and_get_column<ColumnVector<UInt8>>(*const_data_column)) {
-                if (res_col->get_data()[0] == 0) {
-                    _filtered_rows += block->rows();
-                }
+            auto* constant_val = const_cast<char*>(result_column.column->get_data_at(0).data);
+            if (constant_val == nullptr || !*reinterpret_cast<bool*>(constant_val)) {
+                _filtered_rows += block->rows();
             }
         } else if (const auto* nullable =
                            check_and_get_column<ColumnNullable>(*result_column.column)) {