This is an automated email from the ASF dual-hosted git repository.
gavinchou pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 199580f15c1 [Enhancement](compaction) Add tablet info when cloud
compaction crash (#49296)
199580f15c1 is described below
commit 199580f15c140f4fe330b9292c89825829327c74
Author: abmdocrt <lianyuk...@selectdb.com>
AuthorDate: Sat Mar 22 22:24:24 2025 +0800
[Enhancement](compaction) Add tablet info when cloud compaction crash
(#49296)
---
be/src/cloud/cloud_storage_engine.cpp | 4 ++++
1 file changed, 4 insertions(+)
diff --git a/be/src/cloud/cloud_storage_engine.cpp
b/be/src/cloud/cloud_storage_engine.cpp
index ef532f85f0a..0d29d31be48 100644
--- a/be/src/cloud/cloud_storage_engine.cpp
+++ b/be/src/cloud/cloud_storage_engine.cpp
@@ -41,6 +41,7 @@
#include "cloud/cloud_warm_up_manager.h"
#include "cloud/config.h"
#include "common/config.h"
+#include "common/signal_handler.h"
#include "common/status.h"
#include "io/cache/block_file_cache_downloader.h"
#include "io/cache/block_file_cache_factory.h"
@@ -611,6 +612,7 @@ Status
CloudStorageEngine::_submit_base_compaction_task(const CloudTabletSPtr& t
_submitted_base_compactions[tablet->tablet_id()] = compaction;
}
st = _base_compaction_thread_pool->submit_func([=, this, compaction =
std::move(compaction)]() {
+ signal::tablet_id = tablet->tablet_id();
auto st = compaction->execute_compact();
if (!st.ok()) {
// Error log has been output in `execute_compact`
@@ -680,6 +682,7 @@ Status
CloudStorageEngine::_submit_cumulative_compaction_task(const CloudTabletS
}
};
st = _cumu_compaction_thread_pool->submit_func([=, compaction =
std::move(compaction)]() {
+ signal::tablet_id = tablet->tablet_id();
auto st = compaction->execute_compact();
if (!st.ok()) {
// Error log has been output in `execute_compact`
@@ -723,6 +726,7 @@ Status
CloudStorageEngine::_submit_full_compaction_task(const CloudTabletSPtr& t
_submitted_full_compactions[tablet->tablet_id()] = compaction;
}
st = _base_compaction_thread_pool->submit_func([=, this, compaction =
std::move(compaction)]() {
+ signal::tablet_id = tablet->tablet_id();
auto st = compaction->execute_compact();
if (!st.ok()) {
// Error log has been output in `execute_compact`
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
