Skip to content

Commit

Permalink
[BugFix] Fix OlapTableSink close accelerate release resource (#8893) (#…
Browse files Browse the repository at this point in the history
…8911)

(cherry picked from commit b310b48)

Co-authored-by: meegoo <hujie-dlut@qq.com>
  • Loading branch information
mergify[bot] and meegoo committed Jul 19, 2022
1 parent 110cb4d commit 56c7249
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion be/src/exec/tablet_sink.cpp
Expand Up @@ -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());
}
Expand Down

0 comments on commit 56c7249

Please sign in to comment.