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

fix bug: get a deduction type that is not what you expected by using auto

Browse Source
This commit is contained in:
obdev
2023-08-02 09:18:27 +00:00
committed by ob-robot
parent 4643425ad2
commit 9dab2044da
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/sql/engine/px/p2p_datahub/ob_runtime_filter_msg.cpp
View File

@ -732,7 +732,7 @@ int ObRFBloomFilterMsg::broadcast(ObIArray<ObAddr> &target_addrs,
cur_idx = ATOMIC_FAA(filter_idx_, 1); cur_idx = ATOMIC_FAA(filter_idx_, 1);
if (cur_idx < filter_indexes_.count()) { if (cur_idx < filter_indexes_.count()) {
msg.next_peer_addrs_.reuse(); msg.next_peer_addrs_.reuse();
auto addr_filter_idx = filter_indexes_.at(cur_idx); const BloomFilterIndex &addr_filter_idx = filter_indexes_.at(cur_idx);
msg.bloom_filter_.set_begin_idx(addr_filter_idx.begin_idx_); msg.bloom_filter_.set_begin_idx(addr_filter_idx.begin_idx_);
msg.bloom_filter_.set_end_idx(addr_filter_idx.end_idx_); msg.bloom_filter_.set_end_idx(addr_filter_idx.end_idx_);
if (OB_FAIL(msg.next_peer_addrs_.init(addr_filter_idx.channel_ids_.count()))) { if (OB_FAIL(msg.next_peer_addrs_.init(addr_filter_idx.channel_ids_.count()))) {