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

Refine log in MicroBlockRowLockMultiChecker

Browse Source
This commit is contained in:
wudidapaopao
2023-11-28 13:42:01 +00:00
committed by ob-robot
parent 4639d805d9
commit 4610ed123a
1 changed files with 12 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
src/storage/blocksstable/ob_micro_block_row_lock_checker.cpp
View File

@ -287,16 +287,16 @@ int ObMicroBlockRowLockMultiChecker::check_row(
rows_info_->set_conflict_rowkey(rowkey_idx); rows_info_->set_conflict_rowkey(rowkey_idx);
rows_info_->set_error_code(OB_TRY_LOCK_ROW_CONFLICT); rows_info_->set_error_code(OB_TRY_LOCK_ROW_CONFLICT);
need_stop = true; need_stop = true;
LOG_WARN("Find lock conflict in mini/minor sstable", K(rowkey_idx), K(rows_info_->rowkeys_[rowkey_idx]), LOG_DEBUG("Find lock conflict in mini/minor sstable", K(rowkey_idx), K(rows_info_->rowkeys_[rowkey_idx]),
K_(rowkey_current_idx), K_(rowkey_begin_idx), K_(rowkey_end_idx), K_(empty_read_cnt), K(lock_state), K_(rowkey_current_idx), K_(rowkey_begin_idx), K_(rowkey_end_idx), K_(empty_read_cnt), K(lock_state),
K(inner_dml_flag), K_(current), K_(start), K_(last), K(row_lock_checked), K_(macro_id)); K(inner_dml_flag), K_(current), K_(start), K_(last), K(row_lock_checked), K_(macro_id));
} else if (lock_state.trans_version_ > snapshot_version_) { } else if (lock_state.trans_version_ > snapshot_version_) {
rows_info_->set_conflict_rowkey(rowkey_idx); rows_info_->set_conflict_rowkey(rowkey_idx);
rows_info_->set_error_code(OB_TRANSACTION_SET_VIOLATION); rows_info_->set_error_code(OB_TRANSACTION_SET_VIOLATION);
need_stop = true; need_stop = true;
LOG_WARN("Find tsv conflict in mini/minor sstable", K(rowkey_idx), K(rows_info_->rowkeys_[rowkey_idx]), LOG_DEBUG("Find tsv conflict in mini/minor sstable", K(rowkey_idx), K(rows_info_->rowkeys_[rowkey_idx]),
K_(rowkey_current_idx), K_(rowkey_begin_idx), K_(rowkey_end_idx), K_(empty_read_cnt), K(lock_state), K_(rowkey_current_idx), K_(rowkey_begin_idx), K_(rowkey_end_idx), K_(empty_read_cnt), K(lock_state),
K(inner_dml_flag), K_(current), K_(start), K_(last), K(row_lock_checked), K_(macro_id)); K(inner_dml_flag), K_(current), K_(start), K_(last), K(row_lock_checked), K_(macro_id));
} else { } else {
rows_info_->set_row_lock_checked(rowkey_idx, check_exist_); rows_info_->set_row_lock_checked(rowkey_idx, check_exist_);
} }
@ -309,9 +309,9 @@ int ObMicroBlockRowLockMultiChecker::check_row(
rows_info_->set_conflict_rowkey(rowkey_idx); rows_info_->set_conflict_rowkey(rowkey_idx);
rows_info_->set_error_code(OB_ERR_PRIMARY_KEY_DUPLICATE); rows_info_->set_error_code(OB_ERR_PRIMARY_KEY_DUPLICATE);
need_stop = true; need_stop = true;
LOG_WARN("Find duplication in mini/minor sstable", K(rowkey_idx), K(rows_info_->rowkeys_[rowkey_idx]), LOG_DEBUG("Find duplication in mini/minor sstable", K(rowkey_idx), K(rows_info_->rowkeys_[rowkey_idx]),
K_(rowkey_current_idx), K_(rowkey_begin_idx), K_(rowkey_end_idx), K_(empty_read_cnt), K(lock_state), K_(rowkey_current_idx), K_(rowkey_begin_idx), K_(rowkey_end_idx), K_(empty_read_cnt), K(lock_state),
K(inner_dml_flag), K_(current), K_(start), K_(last), K(row_lock_checked), K_(macro_id)); K(inner_dml_flag), K_(current), K_(start), K_(last), K(row_lock_checked), K_(macro_id));
} else { } else {
rows_info_->set_row_checked(rowkey_idx); rows_info_->set_row_checked(rowkey_idx);
} }
@ -328,9 +328,9 @@ void ObMicroBlockRowLockMultiChecker::check_row_in_major_sstable(bool &need_stop
rows_info_->set_conflict_rowkey(rowkey_idx); rows_info_->set_conflict_rowkey(rowkey_idx);
rows_info_->set_error_code(OB_ERR_PRIMARY_KEY_DUPLICATE); rows_info_->set_error_code(OB_ERR_PRIMARY_KEY_DUPLICATE);
need_stop = true; need_stop = true;
LOG_WARN_RET(OB_SUCCESS, "Find duplication in major sstable", K(rowkey_idx), K(rows_info_->rowkeys_[rowkey_idx]), LOG_DEBUG("Find duplication in major sstable", K(rowkey_idx), K(rows_info_->rowkeys_[rowkey_idx]),
K_(rowkey_current_idx), K_(rowkey_begin_idx), K_(rowkey_end_idx), K_(empty_read_cnt), K_(rowkey_current_idx), K_(rowkey_begin_idx), K_(rowkey_end_idx), K_(empty_read_cnt),
K_(current), K_(start), K_(last), K_(macro_id)); K_(current), K_(start), K_(last), K_(macro_id));
} else { } else {
rows_info_->set_row_checked(rowkey_idx); rows_info_->set_row_checked(rowkey_idx);
} }