From ccb97c71a4faf1a672a09c93cc9baf98c4291430 Mon Sep 17 00:00:00 2001
From: liaoxin <liaoxinbit@126.com>
Date: Wed, 9 Nov 2022 17:16:17 +0800
Subject: [PATCH] [fix](load) fix that load channel failed to be released in
 time

---
 be/src/exec/tablet_sink.cpp | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/be/src/exec/tablet_sink.cpp b/be/src/exec/tablet_sink.cpp
index a7e03c11e2c502..0da26b8d429fa7 100644
--- a/be/src/exec/tablet_sink.cpp
+++ b/be/src/exec/tablet_sink.cpp
@@ -1114,6 +1114,8 @@ Status OlapTableSink::close(RuntimeState* state, Status close_status) {
                             if (!s.ok()) {
                                 index_channel->mark_as_failed(ch->node_id(), ch->host(),
                                                               s.get_error_msg(), -1);
+                                // cancel the node channel in best effort
+                                ch->cancel(s.get_error_msg());
                                 LOG(WARNING)
                                         << ch->channel_info()
                                         << ", close channel failed, err: " << s.get_error_msg();