[feature](selectdb-cloud) Pick "[fix](load) fix that load channel fai…

…led to be released in time (apache#14119)" commit 3690c4d Author: Xin Liao <liaoxinbit@126.com> Date: Wed Nov 9 22:38:08 2022 +0800 [fix](load) fix that load channel failed to be released in time (apache#14119)
luwei16 · Nov 18, 2022 · 8a84b89 · 8a84b89
1 parent ac202c7
commit 8a84b89
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/be/src/exec/tablet_sink.cpp b/be/src/exec/tablet_sink.cpp
@@ -1086,6 +1086,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();