提交 8dd6b41e 编写于 作者: O obdev 提交者: ob-robot

fix dtl channel can not detect interrupt && fix hash join memory dynamic leak

上级 1f41bcc0
......@@ -312,7 +312,7 @@ int ObDtlChannelLoop::process_base(ObIDltChannelLoopPred *pred, int64_t &hinted_
}
}
}
if (OB_FAIL(ret)) {
if (OB_UNLIKELY(OB_RPC_CONNECT_ERROR == ret)) {
} else if (ignore_interrupt_) {
// do nothing.
} else if ((loop_times_ & (INTERRUPT_CHECK_TIMES - 1)) == 0 && OB_UNLIKELY(IS_INTERRUPTED())) {
......
......@@ -1185,7 +1185,7 @@ private:
common::ObIAllocator *alloc_; // for buckets
ModulePageAllocator *bloom_filter_alloc_;
ObGbyBloomFilter *bloom_filter_;
common::ObBitSet<common::OB_DEFAULT_BITSET_SIZE, common::ModulePageAllocator, true>
common::ObBitSet<common::OB_DEFAULT_BITSET_SIZE, common::ModulePageAllocator>
right_bit_set_;
int64_t nth_right_row_;
int64_t ltb_size_;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册