From f6e8a07bcc8cf73a3f4621c0126abf97c353c8fd Mon Sep 17 00:00:00 2001 From: obdev Date: Tue, 25 Oct 2022 14:25:12 +0800 Subject: [PATCH] Merge branch issue/45639702 into master --- src/sql/engine/px/ob_px_interruption.cpp | 18 ++++++++---------- 1 file changed, 8 insertions(+), 10 deletions(-) diff --git a/src/sql/engine/px/ob_px_interruption.cpp b/src/sql/engine/px/ob_px_interruption.cpp index e9a503242..a2789f904 100644 --- a/src/sql/engine/px/ob_px_interruption.cpp +++ b/src/sql/engine/px/ob_px_interruption.cpp @@ -64,16 +64,14 @@ int ObInterruptUtil::broadcast_dfo(ObDfo *dfo, int code) // 暂存上次的 id，inc_seqnum 将修改 px_interrupt_id_ ObInterruptibleTaskID interrupt_id = dfo->get_interrupt_id().px_interrupt_id_; for (int64_t j = 0; j < sqcs.count(); ++j) { - if (sqcs.at(j)->need_report()) { - const ObAddr &addr = sqcs.at(j)->get_exec_addr(); - if(OB_SUCCESS != (tmp_ret = manager->interrupt(addr, interrupt_id, int_code))) { - ret = tmp_ret; - LOG_WARN("fail to send interrupt message to other server", - K(ret), K(int_code), K(addr), K(interrupt_id)); - } else { - LOG_INFO("success to send interrupt message", - K(int_code), K(addr), K(interrupt_id)); - } + const ObAddr &addr = sqcs.at(j)->get_exec_addr(); + if(OB_SUCCESS != (tmp_ret = manager->interrupt(addr, interrupt_id, int_code))) { + ret = tmp_ret; + LOG_WARN("fail to send interrupt message to other server", + K(ret), K(int_code), K(addr), K(interrupt_id)); + } else { + LOG_INFO("success to send interrupt message", + K(int_code), K(addr), K(interrupt_id)); } } }