From a82f03b051a24af5fe17a2a5f9215ad6d5d16f77 Mon Sep 17 00:00:00 2001 From: obdev Date: Thu, 23 May 2024 08:46:23 +0000 Subject: [PATCH] fix transfer move create tx_ctx on dest_ls when replay from middle --- src/storage/tx/ob_trans_ctx_mgr_v4.cpp | 7 +------ 1 file changed, 1 insertion(+), 6 deletions(-) diff --git a/src/storage/tx/ob_trans_ctx_mgr_v4.cpp b/src/storage/tx/ob_trans_ctx_mgr_v4.cpp index af6e25535..6a6f2272d 100644 --- a/src/storage/tx/ob_trans_ctx_mgr_v4.cpp +++ b/src/storage/tx/ob_trans_ctx_mgr_v4.cpp @@ -2727,13 +2727,8 @@ int ObLSTxCtxMgr::move_tx_op(const ObTransferMoveTxParam &move_tx_param, // b. when on_register part failure do abort allow no this ctx TRANS_LOG(WARN, "tx.ctx not exist when transfer on abort can skip", K(arg)); continue; - } else if (move_tx_param.is_incomplete_replay_ && !is_exist) { - TRANS_LOG(WARN, "tx.ctx not exist may incomplete replay can skip", K(arg)); - continue; } else if (!is_exist) { - if (!is_replay && (move_tx_param.op_type_ == NotifyType::ON_REDO || move_tx_param.op_type_ == NotifyType::ON_COMMIT)) { - TRANS_LOG(WARN, "tx ctx not exist", K(ls_id_), K(move_tx_param), K(arg)); - } + TRANS_LOG(INFO, "tx ctx not exist need to create", K(ls_id_), K(move_tx_param), K(arg)); ObTxCreateArg create_arg(!is_master(), PartCtxSource::TRANSFER, tenant_id_,