From 0542517185f59543bab095518590ced5004e9f14 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) (cherry picked from commit b310b4858a07c82abb83c87851620b323bec99ca) --- 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 5542d34f7f46e..fd3fb823c61c1 100644 --- a/be/src/exec/tablet_sink.cpp +++ b/be/src/exec/tablet_sink.cpp @@ -989,7 +989,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()); }