This is an automated email from the ASF dual-hosted git repository.
morrysnow pushed a commit to branch branch-3.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.1 by this push:
new c90bf0c2ace branch-3.1: [fix](cloud) Fix unhandled error when
get_partition_boundaries #56935 (#56968)
c90bf0c2ace is described below
commit c90bf0c2ace388749929bea68129a78bb805429a
Author: Gavin Chou <[email protected]>
AuthorDate: Wed Oct 15 11:28:39 2025 +0800
branch-3.1: [fix](cloud) Fix unhandled error when get_partition_boundaries
#56935 (#56968)
pick #56935
---
cloud/src/meta-store/txn_kv.cpp | 19 +++++++++++++------
1 file changed, 13 insertions(+), 6 deletions(-)
diff --git a/cloud/src/meta-store/txn_kv.cpp b/cloud/src/meta-store/txn_kv.cpp
index 23df51d5ac8..bef83aaee5a 100644
--- a/cloud/src/meta-store/txn_kv.cpp
+++ b/cloud/src/meta-store/txn_kv.cpp
@@ -114,29 +114,36 @@ TxnErrorCode
FdbTxnKv::get_partition_boundaries(std::vector<std::string>* bounda
std::string end_key(fdb_partition_key_end());
std::unique_ptr<RangeGetIterator> iter;
- do {
+ int num_iterations = 0;
+ int num_kvs = 0;
+ while (iter == nullptr /* may be not init */ || iter->more()) {
code = txn->get(begin_key, end_key, &iter, true);
if (code != TxnErrorCode::TXN_OK) {
+ LOG_WARNING("failed to get fdb boundaries")
+ .tag("code", code)
+ .tag("begin_key", hex(begin_key))
+ .tag("end_key", hex(end_key))
+ .tag("num_iterations", num_iterations)
+ .tag("num_kvs", num_kvs);
if (code == TxnErrorCode::TXN_TOO_OLD) {
code = create_txn_with_system_access(&txn);
if (code == TxnErrorCode::TXN_OK) {
continue;
}
}
- LOG_WARNING("failed to get fdb boundaries")
- .tag("code", code)
- .tag("begin_key", hex(begin_key))
- .tag("end_key", hex(end_key));
+ LOG_WARNING("failed to recreate txn when get fdb
boundaries").tag("code", code);
return code;
}
while (iter->has_next()) {
auto&& [key, value] = iter->next();
boundaries->emplace_back(key);
+ ++num_kvs;
}
begin_key = iter->next_begin_key();
- } while (iter->more());
+ ++num_iterations;
+ }
return TxnErrorCode::TXN_OK;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
