diff --git a/src/sql/dtl/ob_dtl_flow_control.h b/src/sql/dtl/ob_dtl_flow_control.h index d8e9229fe4b5c62402b5d4498e6db70301c55dbf..a177366451de98fc9ac2709bacd62eb88ab421ec 100644 --- a/src/sql/dtl/ob_dtl_flow_control.h +++ b/src/sql/dtl/ob_dtl_flow_control.h @@ -94,7 +94,6 @@ public: blocks_(), chans_(), drain_ch_cnt_(0), - receive_ch_sets_(), dfo_key_(), op_metric_(nullptr), first_buf_cache_(nullptr), @@ -219,6 +218,7 @@ public: { chans_.reset(); blocks_.reset(); + ch_info_ = nullptr; is_init_ = false; } @@ -288,10 +288,6 @@ public: { dfo_key_ = key; } - ObPxTaskChSets& get_all_ch_set_for_update() - { - return receive_ch_sets_; - } ObDtlLocalFirstBufferCache* get_first_buffer_cache() { @@ -342,7 +338,6 @@ private: common::ObSEArray chans_; uint64_t drain_ch_cnt_; - ObPxTaskChSets receive_ch_sets_; ObDtlDfoKey dfo_key_; sql::ObOpMetric* op_metric_;