hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

fix __all_virtual_tenant_snapshot_ls_replica_history fail to decode hex string into ls_meta_package

Browse Source
This commit is contained in:
obdev
2023-12-14 13:43:21 +00:00
committed by ob-robot
parent 64aa27183b
commit c12d0eeaad
2 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/observer/virtual_table/ob_all_virtual_tenant_snapshot_ls_replica.cpp
View File

@ -116,7 +116,9 @@ int ObAllVirtualTenantSnapshotLSReplica::process_curr_tenant(ObNewRow *&row)
if (LS_META_PACKAGE == col_id) { // decode ls_meta_package column if (LS_META_PACKAGE == col_id) { // decode ls_meta_package column
int64_t length = 0; int64_t length = 0;
EXTRACT_VARCHAR_FIELD_MYSQL(*result_, "ls_meta_package", ls_meta_package_str); EXTRACT_VARCHAR_FIELD_MYSQL(*result_, "ls_meta_package", ls_meta_package_str);
if (OB_ISNULL(ls_meta_buf_)) { if (ls_meta_package_str.empty()) {
cur_row_.cells_[i].reset();
} else if (OB_ISNULL(ls_meta_buf_)) {
ret = OB_ERR_UNEXPECTED; ret = OB_ERR_UNEXPECTED;
SERVER_LOG(WARN, "ls_meta_buf_ is null", KR(ret), KP(ls_meta_buf_), KP(allocator_)); SERVER_LOG(WARN, "ls_meta_buf_ is null", KR(ret), KP(ls_meta_buf_), KP(allocator_));
} else if (OB_FAIL(decode_hex_string_to_package_(ls_meta_package_str, *allocator_, ls_meta_package))){ } else if (OB_FAIL(decode_hex_string_to_package_(ls_meta_package_str, *allocator_, ls_meta_package))){

4
src/observer/virtual_table/ob_all_virtual_tenant_snapshot_ls_replica_history.cpp
View File

@ -116,7 +116,9 @@ int ObAllVirtualTenantSnapshotLSReplicaHistory::process_curr_tenant(ObNewRow *&r
if (LS_META_PACKAGE == col_id) { // decode ls_meta_package column if (LS_META_PACKAGE == col_id) { // decode ls_meta_package column
int64_t length = 0; int64_t length = 0;
EXTRACT_VARCHAR_FIELD_MYSQL(*result_, "ls_meta_package", ls_meta_package_str); EXTRACT_VARCHAR_FIELD_MYSQL(*result_, "ls_meta_package", ls_meta_package_str);
if (OB_ISNULL(ls_meta_buf_)) { if (ls_meta_package_str.empty()) {
cur_row_.cells_[i].reset();
} else if (OB_ISNULL(ls_meta_buf_)) {
ret = OB_ERR_UNEXPECTED; ret = OB_ERR_UNEXPECTED;
SERVER_LOG(WARN, "ls_meta_buf_ is null", KR(ret), KP(ls_meta_buf_), KP(allocator_)); SERVER_LOG(WARN, "ls_meta_buf_ is null", KR(ret), KP(ls_meta_buf_), KP(allocator_));
} else if (OB_FAIL(decode_hex_string_to_package_(ls_meta_package_str, *allocator_, ls_meta_package))){ } else if (OB_FAIL(decode_hex_string_to_package_(ls_meta_package_str, *allocator_, ls_meta_package))){