fix load channel may memory leak (#32277)

2024-03-17 11:05:30 +08:00
parent 0990014e94
commit fd1345bef0
1 changed files with 1 additions and 1 deletions
--- a/be/src/vec/sink/writer/vtablet_writer.cpp
+++ b/be/src/vec/sink/writer/vtablet_writer.cpp
@ -916,7 +916,7 @@ Status VNodeChannel::close_wait(RuntimeState* state) {
    _close_time_ms = UnixMillis() - _close_time_ms;

    if (_cancelled || state->is_cancelled()) {
-        _cancel_with_msg(state->cancel_reason());
+        cancel(state->cancel_reason());
    }

    if (_add_batches_finished) {