[doris] branch branch-1.1-lts updated: [fix](load) fix that load channel failed to be released in time (#14119) (#14514)

[yi...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

yiguolei pushed a commit to branch branch-1.1-lts
in repository https://gitbox.apache.org/repos/asf/doris.git


The following commit(s) were added to refs/heads/branch-1.1-lts by this push:
     new c943aa8bf7 [fix](load) fix that load channel failed to be released in time (#14119) (#14514)
c943aa8bf7 is described below

commit c943aa8bf7fd2de3a5cbf8a9683eb2f8aea6f214
Author: Xin Liao <li...@126.com>
AuthorDate: Wed Nov 23 16:19:55 2022 +0800

    [fix](load) fix that load channel failed to be released in time (#14119) (#14514)
---
 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 f4742ab590..f7c4268704 100644
--- a/be/src/exec/tablet_sink.cpp
+++ b/be/src/exec/tablet_sink.cpp
@@ -1053,6 +1053,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();


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org