diff --git a/src/logservice/replayservice/ob_replay_status.cpp b/src/logservice/replayservice/ob_replay_status.cpp index 9fedd00bd..a5dd49d3b 100644 --- a/src/logservice/replayservice/ob_replay_status.cpp +++ b/src/logservice/replayservice/ob_replay_status.cpp @@ -1089,7 +1089,7 @@ int ObReplayStatus::push_log_replay_task(ObLogReplayTask &task) if (OB_UNLIKELY(NULL == (task_buf = rp_sv_->alloc_replay_task(task_size)))) { ret = OB_EAGAIN; if (REACH_TIME_INTERVAL(1 * 1000 * 1000)) { - CLOG_LOG(WARN, "failed to alloc replay task buf when broadcast pre barrier", K(ret)); + CLOG_LOG(WARN, "failed to alloc replay task buf when broadcast pre barrier", K(i), K(ret)); } } else { ObLogReplayTask *replay_task = new (task_buf) ObLogReplayTask(); @@ -1120,7 +1120,7 @@ int ObReplayStatus::push_log_replay_task(ObLogReplayTask &task) task_queues_[index].set_batch_push_finish(); } } else { - for (int64_t i = 1; OB_SUCC(ret) && i < broadcast_task_array.count(); ++i) { + for (int64_t i = 1; i < broadcast_task_array.count(); ++i) { free_replay_task(broadcast_task_array[i]); } }