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 da37cabc903 [Cherry-Pick](branch-3.0) Pick "[Enhancement](Log) Missing
rowset clone should not print stack log (#53193)" (#53527)
da37cabc903 is described below
commit da37cabc903cfae22602978f0b4534c5659de4fc
Author: abmdocrt <[email protected]>
AuthorDate: Sun Jul 20 21:59:46 2025 +0800
[Cherry-Pick](branch-3.0) Pick "[Enhancement](Log) Missing rowset clone
should not print stack log (#53193)" (#53527)
Pick #53193
---
be/src/olap/cumulative_compaction.cpp | 2 +-
be/src/olap/storage_engine.cpp | 5 +++--
be/src/olap/task/engine_publish_version_task.cpp | 2 +-
3 files changed, 5 insertions(+), 4 deletions(-)
diff --git a/be/src/olap/cumulative_compaction.cpp
b/be/src/olap/cumulative_compaction.cpp
index 2a2fdb51eb2..8db397aa577 100644
--- a/be/src/olap/cumulative_compaction.cpp
+++ b/be/src/olap/cumulative_compaction.cpp
@@ -206,7 +206,7 @@ Status CumulativeCompaction::pick_rowsets_to_compact() {
Status st = _engine.submit_clone_task(tablet(),
missing_versions.back().first);
if (!st) {
LOG_WARNING("cumulative compaction failed to submit missing
rowset clone task.")
- .tag("st", st.to_string())
+ .tag("st", st.msg())
.tag("tablet_id", _tablet->tablet_id())
.tag("version", missing_versions.back().first)
.tag("replica_id", tablet()->replica_id())
diff --git a/be/src/olap/storage_engine.cpp b/be/src/olap/storage_engine.cpp
index df8c6631e20..bcb9dd8453f 100644
--- a/be/src/olap/storage_engine.cpp
+++ b/be/src/olap/storage_engine.cpp
@@ -1472,6 +1472,7 @@ bool StorageEngine::get_peers_replica_backends(int64_t
tablet_id, std::vector<TB
int64_t cur_time = UnixMillis();
if (cur_time - _last_get_peers_replica_backends_time_ms < 10000) {
LOG_WARNING("failed to get peers replica backens.")
+ .tag("tablet_id", tablet_id)
.tag("last time", _last_get_peers_replica_backends_time_ms)
.tag("cur time", cur_time);
return false;
@@ -1653,8 +1654,8 @@ Status StorageEngine::_persist_broken_paths() {
Status StorageEngine::submit_clone_task(Tablet* tablet, int64_t version) {
std::vector<TBackend> backends;
if (!get_peers_replica_backends(tablet->tablet_id(), &backends)) {
- LOG(WARNING) << tablet->tablet_id() << " tablet doesn't have peer
replica backends";
- return Status::InternalError("");
+ return Status::Error<ErrorCode::INTERNAL_ERROR, false>(
+ "get_peers_replica_backends failed.");
}
TAgentTaskRequest task;
TCloneReq req;
diff --git a/be/src/olap/task/engine_publish_version_task.cpp
b/be/src/olap/task/engine_publish_version_task.cpp
index 6c37e55da75..13e7dcd97aa 100644
--- a/be/src/olap/task/engine_publish_version_task.cpp
+++ b/be/src/olap/task/engine_publish_version_task.cpp
@@ -228,7 +228,7 @@ Status EnginePublishVersionTask::execute() {
if (!st) {
LOG_WARNING(
"mow publish failed to submit missing
rowset clone task.")
- .tag("st", st.to_string())
+ .tag("st", st.msg())
.tag("tablet_id", tablet->tablet_id())
.tag("version", version.first - 1)
.tag("replica_id",
tablet->replica_id())
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
