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

[BUG.FIX] fix rowkey exist

Browse Source
This commit is contained in:
Tyshawn
2023-08-16 08:10:27 +00:00
committed by ob-robot
parent b39b92b3fc
commit 6ec8de9305
1 changed files with 8 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/storage/tablet/ob_tablet.cpp
View File

@ -3024,7 +3024,8 @@ int ObTablet::rowkey_exists(
LOG_WARN("Failed to transfer datum rowkey", K(ret), K(rowkey)); LOG_WARN("Failed to transfer datum rowkey", K(ret), K(rowkey));
} else if (OB_FAIL(prepare_param_ctx(allocator, relative_table, store_ctx, param, context))) { } else if (OB_FAIL(prepare_param_ctx(allocator, relative_table, store_ctx, param, context))) {
LOG_WARN("Failed to prepare param ctx, ", K(ret), K(rowkey)); LOG_WARN("Failed to prepare param ctx, ", K(ret), K(rowkey));
} else if (OB_FAIL(do_rowkey_exists(param, context, datum_rowkey, exists))) { } else if (OB_FAIL(relative_table.tablet_iter_.get_tablet()->do_rowkey_exists(
param, context, datum_rowkey, exists))) {
LOG_WARN("do rowkey exist fail", K(ret), K(rowkey)); LOG_WARN("do rowkey exist fail", K(ret), K(rowkey));
} }
LOG_DEBUG("chaser debug row", K(ret), K(row), K(rowkey)); LOG_DEBUG("chaser debug row", K(ret), K(row), K(rowkey));
@ -3062,11 +3063,13 @@ int ObTablet::rowkeys_exists(
} }
if (OB_SUCC(ret)) { if (OB_SUCC(ret)) {
if (OB_FAIL(auto_get_read_tables(store_ctx.mvcc_acc_ctx_.get_snapshot_version().get_val_for_tx(), if (OB_FAIL(relative_table.tablet_iter_.get_tablet()->auto_get_read_tables(
tables_iter, store_ctx.mvcc_acc_ctx_.get_snapshot_version().get_val_for_tx(),
relative_table.allow_not_ready()))) { tables_iter,
relative_table.allow_not_ready()))) {
LOG_WARN("get read iterator fail", K(ret)); LOG_WARN("get read iterator fail", K(ret));
} else if (OB_FAIL(do_rowkeys_exist(tables_iter.table_store_iter_, rows_info, exists))) { } else if (OB_FAIL(relative_table.tablet_iter_.get_tablet()->do_rowkeys_exist(
tables_iter.table_store_iter_, rows_info, exists))) {
LOG_WARN("fail to check the existence of rows", K(ret), K(rows_info), K(exists)); LOG_WARN("fail to check the existence of rows", K(ret), K(rows_info), K(exists));
} }
} }