update

BiteTheDDDDt · BiteTheDDDDt · commit ccfe0ec06cd9 · 2025-10-30T18:55:08.000+08:00
diff --git a/be/src/runtime_filter/runtime_filter_mgr.cpp b/be/src/runtime_filter/runtime_filter_mgr.cpp
@@ -471,6 +471,7 @@ Status RuntimeFilterMergeControllerEntity::reset_global_rf(
         cnt_val->merger->set_expected_producer_num(producer_size);
         cnt_val->arrive_id.clear();
         cnt_val->source_addrs.clear();
+        cnt_val->done = false;
     }
     return Status::OK();
 }

Original file line number	Diff line number	Diff line change
`@@ -471,6 +471,7 @@ Status RuntimeFilterMergeControllerEntity::reset_global_rf(`
`471`	`471`	`cnt_val->merger->set_expected_producer_num(producer_size);`
`472`	`472`	`cnt_val->arrive_id.clear();`
`473`	`473`	`cnt_val->source_addrs.clear();`
	`474`	`+ cnt_val->done = false;`
`474`	`475`	`}`
`475`	`476`	`return Status::OK();`
`476`	`477`	`}`