update

Author: BiteTheDDDDt

be/src/runtime/fragment_mgr.cpp

@@ -728,8 +728,8 @@ Status FragmentMgr::_get_or_create_query_ctx(const TPipelineFragmentParams& para
                         query_ctx = QueryContext::create(query_id, _exec_env, params.query_options,
                                                          params.coord, params.is_nereids,
                                                          params.current_connect_fe, query_source);
-                        auto query_handle =
-                                std::make_shared<QueryHandle>(query_id, parent.query_options, query_ctx);
+                        auto query_handle = std::make_shared<QueryHandle>(
+                                query_id, parent.query_options, query_ctx);
                         _query_handle_map.insert(query_id, query_handle);
                         query_ctx->set_query_handle(query_handle);
                         SCOPED_SWITCH_THREAD_MEM_TRACKER_LIMITER(query_ctx->query_mem_tracker());

be/src/runtime/query_context.cpp

@@ -102,6 +102,8 @@ QueryContext::QueryContext(TUniqueId query_id, ExecEnv* exec_env,
     _memory_sufficient_dependency =
             pipeline::Dependency::create_unique(-1, -1, "MemorySufficientDependency", true);
 
+    _runtime_filter_mgr = std::make_unique<RuntimeFilterMgr>(true);
+
     _timeout_second = query_options.execution_timeout;
 
     bool is_query_type_valid = query_options.query_type == TQueryType::SELECT ||