hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

Fix px join filter core in assign parameter

Browse Source
This commit is contained in:
qianchanger
2022-11-02 16:11:53 +00:00
committed by wangzelin.wzl
parent a0a8950d59
commit 023eabc089
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/sql/engine/px/ob_px_bloom_filter.cpp
View File

@ -551,7 +551,6 @@ int ObSendBloomFilterP::process_px_bloom_filter_data()
phase_end))) { phase_end))) {
LOG_WARN("fail to process recieve count", K(ret)); LOG_WARN("fail to process recieve count", K(ret));
} }
(void)filter->dec_merge_filter_count();
} }
if (OB_SUCC(ret) && phase_end && arg_.is_first_phase() && !arg_.next_peer_addrs_.empty()) { if (OB_SUCC(ret) && phase_end && arg_.is_first_phase() && !arg_.next_peer_addrs_.empty()) {
@ -584,6 +583,9 @@ int ObSendBloomFilterP::process_px_bloom_filter_data()
} }
} }
} }
if (OB_NOT_NULL(filter)) {
(void)filter->dec_merge_filter_count();
}
return ret; return ret;
} }