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 280aba1fde6 [Fix](case) Fix cold data compaction fault injection case
(#49702)
280aba1fde6 is described below
commit 280aba1fde6702cecac531370384bc96083eace2
Author: abmdocrt <[email protected]>
AuthorDate: Tue Apr 1 10:07:58 2025 +0800
[Fix](case) Fix cold data compaction fault injection case (#49702)
---
be/src/olap/tablet.cpp | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git a/be/src/olap/tablet.cpp b/be/src/olap/tablet.cpp
index c77248d5b37..78cb6f23844 100644
--- a/be/src/olap/tablet.cpp
+++ b/be/src/olap/tablet.cpp
@@ -1043,17 +1043,17 @@ uint32_t Tablet::_calc_cumulative_compaction_score(
if (cumulative_compaction_policy == nullptr) [[unlikely]] {
return 0;
}
- DBUG_EXECUTE_IF("Tablet._calc_cumulative_compaction_score.return", {
- LOG_WARNING("Tablet._calc_cumulative_compaction_score.return")
- .tag("tablet id", tablet_id());
- return 0;
- });
#ifndef BE_TEST
if (_cumulative_compaction_policy == nullptr ||
_cumulative_compaction_policy->name() !=
cumulative_compaction_policy->name()) {
_cumulative_compaction_policy = cumulative_compaction_policy;
}
#endif
+ DBUG_EXECUTE_IF("Tablet._calc_cumulative_compaction_score.return", {
+ LOG_WARNING("Tablet._calc_cumulative_compaction_score.return")
+ .tag("tablet id", tablet_id());
+ return 0;
+ });
return
_cumulative_compaction_policy->calc_cumulative_compaction_score(this);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
