From 10a47db1d79ae04e0cb903f0b65d3956269f10ac Mon Sep 17 00:00:00 2001
From: MuJinqiang <1165845907@qq.com>
Date: Wed, 17 Mar 2021 23:08:30 +0800
Subject: [PATCH] =?UTF-8?q?=E8=A7=A3=E5=86=B3=E5=A4=87=E4=BB=BD=E6=8C=87?=
 =?UTF-8?q?=E5=AE=9A=E6=97=B6=E9=97=B4=E6=81=A2=E5=A4=8D=E6=97=B6=E5=A4=B1?=
 =?UTF-8?q?=E8=B4=A5=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../storage/access/transam/parallel_recovery/txn_redo.cpp       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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;