This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
commit 28c4e6914911a3c8e09ee61e22de4bec82978c9b
Author: Kaijie Chen <c...@apache.org>
AuthorDate: Tue Jan 30 09:44:03 2024 +0800
[fix](move-memtable) check load timeout before close wait (#30526)
---
be/src/vec/sink/writer/vtablet_writer_v2.cpp | 5 +++++
1 file changed, 5 insertions(+)
diff --git a/be/src/vec/sink/writer/vtablet_writer_v2.cpp
b/be/src/vec/sink/writer/vtablet_writer_v2.cpp
index bb4b60a3a86..f2fdbcaece3 100644
--- a/be/src/vec/sink/writer/vtablet_writer_v2.cpp
+++ b/be/src/vec/sink/writer/vtablet_writer_v2.cpp
@@ -553,6 +553,11 @@ Status VTabletWriterV2::close(Status exec_status) {
SCOPED_TIMER(_close_load_timer);
auto remain_ms = _state->execution_timeout() * 1000 -
_timeout_watch.elapsed_time() / 1000 / 1000;
+ if (remain_ms <= 0) {
+ LOG(WARNING) << "load timed out before close waiting, load_id="
+ << print_id(_load_id);
+ return Status::TimedOut("load timed out before close waiting");
+ }
for (const auto& [_, streams] : _streams_for_node) {
for (const auto& stream : streams->streams()) {
RETURN_IF_ERROR(stream->close_wait(remain_ms));
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
