This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new ab75d136895 branch-3.0: [Enhancement](compaction) Add tablet info when
cloud compaction crash #49296 (#49368)
ab75d136895 is described below
commit ab75d136895d68db07fb079034c019436f6ae731
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Mon Mar 24 12:14:25 2025 +0800
branch-3.0: [Enhancement](compaction) Add tablet info when cloud compaction
crash #49296 (#49368)
Cherry-picked from #49296
Co-authored-by: abmdocrt <[email protected]>
---
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 dfa4cdf75f6..2dcc01695d0 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"
@@ -610,6 +611,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`
@@ -679,6 +681,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`
@@ -722,6 +725,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: [email protected]
For additional commands, e-mail: [email protected]
