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

[BUG] put trans_end to the postition that will never fail

Browse Source
This commit is contained in:
Handora 2024-02-07 12:42:21 +00:00 committed by ob-robot
parent 18212d8351
commit c3710189f6
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/storage/tx/ob_trans_part_ctx.cpp
View File

@ -5062,16 +5062,16 @@ int ObPartTransCtx::replay_commit(const ObTxCommitLog &commit_log,
exec_info_.multi_data_source_,
false /* not a force kill */))) {
TRANS_LOG(WARN, "notify table lock failed", KR(ret), "context", *this);
} else if (OB_FAIL(notify_data_source_(NotifyType::ON_COMMIT,
timestamp,
true,
exec_info_.multi_data_source_))) {
TRANS_LOG(WARN, "notify data source failed", KR(ret), K(commit_log));
} else if (OB_FAIL(trans_replay_commit_(ctx_tx_data_.get_commit_version(),
timestamp,
cluster_version_,
checksum))) {
TRANS_LOG(WARN, "trans replay commit failed", KR(ret), "context", *this);
} else if (OB_FAIL(notify_data_source_(NotifyType::ON_COMMIT,
timestamp,
true,
exec_info_.multi_data_source_))) {
TRANS_LOG(WARN, "notify data source failed", KR(ret), K(commit_log));
} else if ((!ctx_tx_data_.is_read_only()) && OB_FAIL(ctx_tx_data_.insert_into_tx_table())) {
TRANS_LOG(WARN, "insert to tx table failed", KR(ret), K(*this));
} else if (is_local_tx_()) {