From cc74381bb93b2ec7be390414ffe672f846383667 Mon Sep 17 00:00:00 2001 From: sdc Date: Wed, 20 Sep 2023 14:11:23 +0000 Subject: [PATCH] [CP] generate new px_sequence_id when register interrupt_id of qc --- src/sql/engine/px/ob_px_coord_op.cpp | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/src/sql/engine/px/ob_px_coord_op.cpp b/src/sql/engine/px/ob_px_coord_op.cpp index 9b52152a53..09e3e655dd 100644 --- a/src/sql/engine/px/ob_px_coord_op.cpp +++ b/src/sql/engine/px/ob_px_coord_op.cpp @@ -359,8 +359,6 @@ int ObPxCoordOp::inner_open() LOG_WARN("init operator context failed", K(ret)); } else if (OB_FAIL(coord_info_.init())) { LOG_WARN("fail to init coord info", K(ret)); - } else if (FALSE_IT(px_sequence_id_ = GCTX.sql_engine_->get_px_sequence_id())) { - LOG_WARN("fail to get px sequence id", K(ret)); } else if (OB_FAIL(register_interrupt())) { LOG_WARN("fail to register interrupt", K(ret)); } else if (OB_NOT_NULL(get_spec().get_phy_plan()) && get_spec().get_phy_plan()->is_enable_px_fast_reclaim() @@ -896,6 +894,7 @@ int ObPxCoordOp::check_all_sqc(ObIArray &active_dfos, int ObPxCoordOp::register_interrupt() { int ret = OB_SUCCESS; + px_sequence_id_ = GCTX.sql_engine_->get_px_sequence_id(); ObInterruptUtil::generate_query_interrupt_id((uint32_t)GCTX.server_id_, px_sequence_id_, interrupt_id_);