This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-4.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-4.1 by this push:
new 3e01e0f8dc2 branch-4.1: [fix](cloud) recycler
decrement_delete_bitmap_packed_file_ref_counts method should read delete
bitmaps as blobs #66728 (#66892)
3e01e0f8dc2 is described below
commit 3e01e0f8dc2296f8ce13baed76caade7641411fe
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Thu Aug 20 09:16:14 2026 +0800
branch-4.1: [fix](cloud) recycler
decrement_delete_bitmap_packed_file_ref_counts method should read delete
bitmaps as blobs #66728 (#66892)
Cherry-picked from #66728
Co-authored-by: meiyi <[email protected]>
---
cloud/src/recycler/recycler.cpp | 6 +++---
cloud/test/recycler_test.cpp | 5 +----
2 files changed, 4 insertions(+), 7 deletions(-)
diff --git a/cloud/src/recycler/recycler.cpp b/cloud/src/recycler/recycler.cpp
index 41f1c5ce3d0..f64ab6a38f3 100644
--- a/cloud/src/recycler/recycler.cpp
+++ b/cloud/src/recycler/recycler.cpp
@@ -3625,8 +3625,8 @@ int
InstanceRecycler::decrement_delete_bitmap_packed_file_ref_counts(
return -1;
}
- std::string dbm_val;
- err = txn->get(dbm_key, &dbm_val);
+ ValueBuf dbm_val;
+ err = cloud::blob_get(txn.get(), dbm_key, &dbm_val);
if (err == TxnErrorCode::TXN_KEY_NOT_FOUND) {
// No delete bitmap for this rowset, nothing to do
LOG_INFO("delete bitmap not found, skip packed file ref count
decrement")
@@ -3645,7 +3645,7 @@ int
InstanceRecycler::decrement_delete_bitmap_packed_file_ref_counts(
}
DeleteBitmapStoragePB storage;
- if (!storage.ParseFromString(dbm_val)) {
+ if (!dbm_val.to_pb(&storage)) {
LOG_WARNING("failed to parse delete bitmap storage")
.tag("instance_id", instance_id_)
.tag("tablet_id", tablet_id)
diff --git a/cloud/test/recycler_test.cpp b/cloud/test/recycler_test.cpp
index 54a28553b3d..508014fc7b1 100644
--- a/cloud/test/recycler_test.cpp
+++ b/cloud/test/recycler_test.cpp
@@ -248,13 +248,10 @@ static int create_delete_bitmaps_v2(TxnKv* txn_kv,
StorageVaultAccessor* accesso
return -1;
}
- DeleteBitmapPB delete_bitmap;
DeleteBitmapStoragePB delete_bitmap_storage;
delete_bitmap_storage.set_store_in_fdb(false);
auto key = versioned::meta_delete_bitmap_key({instance_id, tablet_id,
rowset_id});
- std::string val;
- delete_bitmap_storage.SerializeToString(&val);
- txn->put(key, val);
+ cloud::blob_put(txn.get(), key, delete_bitmap_storage, 0);
if (txn->commit() != TxnErrorCode::TXN_OK) {
return -1;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
