diff --git a/src/sql/dtl/ob_dtl_channel_loop.cpp b/src/sql/dtl/ob_dtl_channel_loop.cpp index aa5731f03..2beb7a24b 100644 --- a/src/sql/dtl/ob_dtl_channel_loop.cpp +++ b/src/sql/dtl/ob_dtl_channel_loop.cpp @@ -373,12 +373,7 @@ int ObDtlChannelLoop::process_channels(ObIDltChannelLoopPred *pred, int64_t &nth LOG_WARN("unexpect next idx", K(next_idx_), K(chan_cnt), K(ret)); } else { chan = chans_[next_idx_]; - if (OB_UNLIKELY(ObPxCheckAlive::is_in_blacklist(chan->get_peer(), get_process_query_time()))) { - ret = OB_RPC_CONNECT_ERROR; - LOG_WARN("peer no in communication, maybe crashed", K(ret), K(chan->get_peer()), - K(static_cast(GCONF.cluster_id))); - break; - } else if (nullptr == pred || pred->pred_process(next_idx_, chan)) { + if (nullptr == pred || pred->pred_process(next_idx_, chan)) { if (OB_SUCC(chan->process1(&process_func_, 0, last_row_in_buffer))) { nth_channel = next_idx_; first_data_get_ = true; diff --git a/src/sql/dtl/ob_dtl_channel_loop.h b/src/sql/dtl/ob_dtl_channel_loop.h index 49f9ba1c1..3f53dec0e 100644 --- a/src/sql/dtl/ob_dtl_channel_loop.h +++ b/src/sql/dtl/ob_dtl_channel_loop.h @@ -123,7 +123,7 @@ public: void set_interm_result(bool flag) { use_interm_result_ = flag; } private: static const int64_t INTERRUPT_CHECK_TIMES = 16; - static const int64_t SERVER_ALIVE_CHECK_TIMES = 256; + static const int64_t SERVER_ALIVE_CHECK_TIMES = 4096; Proc *proc_map_[MAX_PROCS]; InterruptProc *interrupt_proc_; common::ObSEArray chans_;