Skip to content

Commit c943aa8

Browse files
authored
[fix](load) fix that load channel failed to be released in time (#14119) (#14514)
1 parent 0237208 commit c943aa8

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

be/src/exec/tablet_sink.cpp

+2
Original file line numberDiff line numberDiff line change
@@ -1053,6 +1053,8 @@ Status OlapTableSink::close(RuntimeState* state, Status close_status) {
10531053
if (!s.ok()) {
10541054
index_channel->mark_as_failed(ch->node_id(), ch->host(),
10551055
s.get_error_msg(), -1);
1056+
// cancel the node channel in best effort
1057+
ch->cancel(s.get_error_msg());
10561058
LOG(WARNING)
10571059
<< ch->channel_info()
10581060
<< ", close channel failed, err: " << s.get_error_msg();

0 commit comments

Comments
 (0)