Skip to content

Commit ccb97c7

Browse files
committed
[fix](load) fix that load channel failed to be released in time
1 parent 322ac5c commit ccb97c7

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
@@ -1114,6 +1114,8 @@ Status OlapTableSink::close(RuntimeState* state, Status close_status) {
11141114
if (!s.ok()) {
11151115
index_channel->mark_as_failed(ch->node_id(), ch->host(),
11161116
s.get_error_msg(), -1);
1117+
// cancel the node channel in best effort
1118+
ch->cancel(s.get_error_msg());
11171119
LOG(WARNING)
11181120
<< ch->channel_info()
11191121
<< ", close channel failed, err: " << s.get_error_msg();

0 commit comments

Comments
 (0)