From 02c9a7cf1995254a15d60d079956ac8dc73198ac Mon Sep 17 00:00:00 2001 From: obdev Date: Tue, 6 Aug 2024 13:57:51 +0000 Subject: [PATCH] Fix incorrect buffer length when fetch macro meta --- src/storage/high_availability/ob_storage_ha_reader.cpp | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/storage/high_availability/ob_storage_ha_reader.cpp b/src/storage/high_availability/ob_storage_ha_reader.cpp index 25bd180059..5f8075f0fc 100644 --- a/src/storage/high_availability/ob_storage_ha_reader.cpp +++ b/src/storage/high_availability/ob_storage_ha_reader.cpp @@ -788,7 +788,7 @@ int ObCopyMacroBlockObProducer::get_next_macro_block( LOG_WARN("failed to build macro row", K(ret), KPC(copy_macro_block_handle_[handle_idx_].macro_meta_)); } else if (OB_FAIL(meta_row_buf_.write_serialize(macro_meta_row))) { LOG_WARN("failed to write serialize macro meta row into meta row buf", K(ret), K(macro_meta_row), K_(meta_row_buf)); - } else if (FALSE_IT(occupy_size = meta_row_buf_.get_serialize_size())) { + } else if (FALSE_IT(occupy_size = meta_row_buf_.length())) { } else { data.assign(meta_row_buf_.data(), occupy_size); copy_macro_block_header.occupy_size_ = occupy_size; @@ -3352,7 +3352,7 @@ int ObCopyRemoteSSTableMacroBlockRestoreReader::get_next_macro_block( LOG_WARN("failed to build macro row", K(ret), K(macro_meta)); } else if (OB_FAIL(meta_row_buf_.write_serialize(macro_meta_row))) { LOG_WARN("failed to write serialize macro meta row into meta row buf", K(ret), K(macro_meta_row), K_(meta_row_buf)); - } else if (FALSE_IT(occupy_size = meta_row_buf_.get_serialize_size())) { + } else if (FALSE_IT(occupy_size = meta_row_buf_.length())) { } else { data.assign(meta_row_buf_.data(), occupy_size); header.occupy_size_ = occupy_size;