From b460379918ba9757a7be0da5943bf2a2464ede1f Mon Sep 17 00:00:00 2001
From: chentingting <2393940156@qq.com>
Date: Mon, 15 Apr 2024 17:45:56 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E5=AE=9E=E6=97=B6=E6=9E=84?=
 =?UTF-8?q?=E5=BB=BA=E6=97=B6dw=5Finit=E5=8D=A1=E4=BD=8F=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/gausskernel/ddes/adapter/ss_dms_recovery.cpp | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/src/gausskernel/ddes/adapter/ss_dms_recovery.cpp b/src/gausskernel/ddes/adapter/ss_dms_recovery.cpp
index 27346892f..68eebafb8 100644
--- a/src/gausskernel/ddes/adapter/ss_dms_recovery.cpp
+++ b/src/gausskernel/ddes/adapter/ss_dms_recovery.cpp
@@ -305,7 +305,13 @@ void OndemandRealtimeBuildHandleFailover()
     Assert(SS_ONDEMAND_REALTIME_BUILD_NORMAL);
 
     SSReadControlFile(SSGetPrimaryInstId());
-    ss_failover_dw_init();
+    if (u_sess->storage_cxt.pendingOps == NULL) {
+        InitSync();
+        ss_failover_dw_init();
+        EnableSyncRequestForwarding();
+    } else {
+        ss_failover_dw_init();
+    }
     StartupOndemandRecovery();
     StartupReplicationSlots();
     restoreTwoPhaseData();