diff --git a/src/logservice/restoreservice/ob_remote_fetch_log_worker.cpp b/src/logservice/restoreservice/ob_remote_fetch_log_worker.cpp
index 6a53557c4f..d1c2874890 100644
--- a/src/logservice/restoreservice/ob_remote_fetch_log_worker.cpp
+++ b/src/logservice/restoreservice/ob_remote_fetch_log_worker.cpp
@@ -280,6 +280,16 @@ int ObRemoteFetchWorker::handle_single_task_()
     if (is_fatal_error_(ret) && need_fetch_log_(task->id_)) {
       report_error_(id, ret, cur_lsn, ObLogRestoreErrorContext::ErrorType::FETCH_LOG);
     }
+//errsim: inject restore failed error
+#ifdef ERRSIM
+  if (OB_SUCC(ret)) {
+    ret = OB_E(EventTable::EN_RESTORE_LOG_FAILED) OB_SUCCESS;
+    if (OB_FAIL(ret) && is_fatal_error_(ret)) {
+      report_error_(id, ret, cur_lsn, ObLogRestoreErrorContext::ErrorType::FETCH_LOG);
+      LOG_WARN("inject restore failed error", K(ret));
+    }
+  }
+#endif
   }
   return ret;
 }
@@ -329,12 +339,6 @@ int ObRemoteFetchWorker::handle_fetch_log_task_(ObFetchLogTask *task)
       LOG_WARN("retire task failed", K(tmp_ret), KP(task));
     }
   }
-
-#ifdef ERRSIM
-  if (OB_SUCC(ret)) {
-    ret = OB_E(EventTable::EN_RESTORE_LOG_FAILED) OB_SUCCESS;
-  }
-#endif
   return ret;
 }