diff --git a/src/storage/tx/ob_trans_part_ctx.cpp b/src/storage/tx/ob_trans_part_ctx.cpp index 3c1c31e68..ed6005dd8 100644 --- a/src/storage/tx/ob_trans_part_ctx.cpp +++ b/src/storage/tx/ob_trans_part_ctx.cpp @@ -1276,6 +1276,9 @@ int ObPartTransCtx::recover_tx_ctx_table_info(const ObTxCtxTableInfo &ctx_info) if (ObTxState::REDO_COMPLETE == get_downstream_state()) { sub_state_.set_info_log_submitted(); } + if (exec_info_.prepare_version_.is_valid()) { + mt_ctx_.set_trans_version(exec_info_.prepare_version_); + } exec_info_.multi_data_source_.reset(); if (OB_FAIL(ret)) { // do nothing