diff --git a/src/gausskernel/storage/access/transam/parallel_recovery/txn_redo.cpp b/src/gausskernel/storage/access/transam/parallel_recovery/txn_redo.cpp
index e166c8318..f571dbafa 100644
--- a/src/gausskernel/storage/access/transam/parallel_recovery/txn_redo.cpp
+++ b/src/gausskernel/storage/access/transam/parallel_recovery/txn_redo.cpp
@@ -302,7 +302,7 @@ void ApplyReadyTxnLogRecords(TxnRedoWorker *worker, bool forceAll)
                 oldReplayedPageLSN = lrEnd;
             }
             RedoInterruptCallBack();
-        } while (forceAll && XLByteLT(lrEnd, t_thrd.xlog_cxt.EndRecPtr));
+        } while (forceAll && XLByteLT(lrEnd, g_dispatcher->dispatchEndRecPtr));
     }
 
     worker->procHead = item;