fix unexpected prepare version bug

2022-11-04 08:39:14 +00:00 · 2022-11-04 08:39:14 +00:00 · 9cd04f85fe
commit 9cd04f85fe
parent 36e9ddef48
1 changed files with 4 additions and 1 deletions
--- a/src/storage/memtable/ob_memtable_context.cpp
+++ b/src/storage/memtable/ob_memtable_context.cpp
@ -580,7 +580,10 @@ int ObMemtableCtx::trans_replay_end(const bool commit,
    }
  }

-  if (OB_FAIL(trans_end(commit, trans_version, final_log_ts))) {
+  if (OB_FAIL(do_trans_end(commit,
+                           trans_version,
+                           final_log_ts,
+                           commit ? OB_TRANS_COMMITED : OB_TRANS_ROLLBACKED))) {
    TRANS_LOG(ERROR, "trans_end fail", K(ret), K(*this));
  } else {
    ret = cs_ret;