This is an automated email from the ASF dual-hosted git repository. panxiaolei pushed a commit to branch refactor_rf in repository https://gitbox.apache.org/repos/asf/doris.git
commit a5e804f591805fc485b84d5a70b0308752dd39c4 Author: BiteTheDDDDt <[email protected]> AuthorDate: Wed Feb 19 21:12:50 2025 +0800 update --- be/src/runtime_filter/role/merger.h | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/be/src/runtime_filter/role/merger.h b/be/src/runtime_filter/role/merger.h index a2a47315359..3d36353a2b1 100644 --- a/be/src/runtime_filter/role/merger.h +++ b/be/src/runtime_filter/role/merger.h @@ -45,6 +45,7 @@ public: Status merge_from(const RuntimeFilter* other) { _received_producer_num++; + DCHECK_GE(_expected_producer_num, _received_producer_num) << debug_string(); if (_received_producer_num == _expected_producer_num) { _rf_state = State::READY; } @@ -58,8 +59,8 @@ public: void set_expected_producer_num(int num) { _expected_producer_num = num; } bool add_rf_size(uint64_t size) { - DCHECK_GE(_expected_producer_num, _received_rf_size_num) << debug_string(); _received_rf_size_num++; + DCHECK_GE(_expected_producer_num, _received_rf_size_num) << debug_string(); return (_received_rf_size_num == _expected_producer_num); } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
