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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
