[fix](load) skip cancel already cancelled channels (apache#27111)

XuJianxu · Dec 14, 2023 · 297b3aa · 297b3aa
1 parent bf21299
commit 297b3aa
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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;
  }