From b310b4858a07c82abb83c87851620b323bec99ca Mon Sep 17 00:00:00 2001 From: meegoo Date: Tue, 19 Jul 2022 17:40:36 +0800 Subject: [PATCH] [BugFix] Fix OlapTableSink close accelerate release resource (#8893) --- be/src/exec/tablet_sink.cpp | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/be/src/exec/tablet_sink.cpp b/be/src/exec/tablet_sink.cpp index ab12d7f7ce680..bc036ed097c30 100644 --- a/be/src/exec/tablet_sink.cpp +++ b/be/src/exec/tablet_sink.cpp @@ -1001,7 +1001,8 @@ bool OlapTableSink::is_close_done() { Status OlapTableSink::close(RuntimeState* state, Status close_status) { if (close_status.ok()) { do { - RETURN_IF_ERROR(try_close(state)); + close_status = try_close(state); + if (!close_status.ok()) break; SleepFor(MonoDelta::FromMilliseconds(5)); } while (!is_close_done()); }