[Bug](runtime-filter) fix core dump on rf between varchar and char #…

…43758 (#46966) pick from #43758
apache · Jan 14, 2025 · d606557 · d606557
1 parent cc073f0
commit d606557
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/be/src/exprs/bloom_filter_func.h b/be/src/exprs/bloom_filter_func.h
@@ -213,6 +213,7 @@ class BloomFilterFuncBase : public FilterFuncBase {
         _bloom_filter_alloced = other_func->_bloom_filter_alloced;
         _bloom_filter = other_func->_bloom_filter;
         _inited = other_func->_inited;
+        set_filter_id(bloomfilter_func->get_filter_id());
     }
 
     virtual void insert(const void* data) = 0;

diff --git a/be/src/exprs/create_predicate_function.h b/be/src/exprs/create_predicate_function.h
@@ -233,7 +233,8 @@ ColumnPredicate* create_olap_column_predicate(uint32_t column_id,
     std::shared_ptr<BloomFilterFuncBase> filter_olap;
     filter_olap.reset(create_bloom_filter(PT));
     filter_olap->light_copy(filter.get());
-    return new BloomFilterColumnPredicate<PT>(column_id, filter, be_exec_version);
+    // create a new filter to match the input filter and PT. For example, filter may be varchar, but PT is char
+    return new BloomFilterColumnPredicate<PT>(column_id, filter_olap, be_exec_version);
 }
 
 template <PrimitiveType PT>