diff --git a/be/src/pipeline/exec/hashjoin_build_sink.cpp b/be/src/pipeline/exec/hashjoin_build_sink.cpp index f34f835d12..757673c70a 100644 --- a/be/src/pipeline/exec/hashjoin_build_sink.cpp +++ b/be/src/pipeline/exec/hashjoin_build_sink.cpp @@ -388,7 +388,9 @@ HashJoinBuildSinkOperatorX::HashJoinBuildSinkOperatorX(ObjectPool* pool, int ope _partition_exprs(tnode.__isset.distribute_expr_lists && !_is_broadcast_join ? tnode.distribute_expr_lists[1] : std::vector {}), - _use_global_rf(use_global_rf) {} + _use_global_rf(use_global_rf) { + _runtime_filter_descs = tnode.runtime_filters; +} Status HashJoinBuildSinkOperatorX::prepare(RuntimeState* state) { if (_is_broadcast_join) {