Skip to content

Commit fac672a

Browse files
liaoxin01gavinchou
authored andcommitted
[feature](selectdb-cloud) Pick "[fix](load) fix that load channel failed to be released in time (apache#14119)"
commit 3690c4d Author: Xin Liao <[email protected]> Date: Wed Nov 9 22:38:08 2022 +0800 [fix](load) fix that load channel failed to be released in time (apache#14119)
1 parent 3524604 commit fac672a

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
@@ -1080,6 +1080,8 @@ Status OlapTableSink::close(RuntimeState* state, Status close_status) {
10801080
if (!s.ok()) {
10811081
index_channel->mark_as_failed(ch->node_id(), ch->host(),
10821082
s.get_error_msg(), -1);
1083+
// cancel the node channel in best effort
1084+
ch->cancel(s.get_error_msg());
10831085
LOG(WARNING)
10841086
<< ch->channel_info()
10851087
<< ", close channel failed, err: " << s.get_error_msg();

0 commit comments

Comments
 (0)