From afffcfd14c8f557f34400839162aec7acdd399b7 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 eb54d4b5dc..d82168eff3 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; }