From 297b3aa2376682c9314749fae111758ddb5e709c Mon Sep 17 00:00:00 2001 From: Kaijie Chen Date: Thu, 16 Nov 2023 18:38:40 +0800 Subject: [PATCH] [fix](load) skip cancel already cancelled channels (#27111) --- be/src/vec/sink/writer/vtablet_writer.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/be/src/vec/sink/writer/vtablet_writer.cpp b/be/src/vec/sink/writer/vtablet_writer.cpp index eb54d4b5dc34e1..d82168eff35deb 100644 --- a/be/src/vec/sink/writer/vtablet_writer.cpp +++ b/be/src/vec/sink/writer/vtablet_writer.cpp @@ -812,7 +812,7 @@ void VNodeChannel::_add_block_failed_callback(bool is_last_rpc) { } void VNodeChannel::cancel(const std::string& cancel_msg) { - if (_is_closed) { + if (_is_closed || _cancelled) { // skip the channels that have been canceled or close_wait. return; }