From 7497eab926e054b0058f39ac49a21481d7c9c4cc Mon Sep 17 00:00:00 2001
From: Minghao Li <castermode@gmail.com>
Date: Wed, 30 Nov 2022 20:32:43 +0800
Subject: [PATCH] refactor(sync): if already start, force close snapshot
 receiver

---
 source/libs/sync/src/syncSnapshot.c | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/source/libs/sync/src/syncSnapshot.c b/source/libs/sync/src/syncSnapshot.c
index 222b7c4e1e..3722b0f6f5 100644
--- a/source/libs/sync/src/syncSnapshot.c
+++ b/source/libs/sync/src/syncSnapshot.c
@@ -541,6 +541,10 @@ _START_RECEIVER:
       taosMsleep(10);
     }
 
+    if (snapshotReceiverIsStart(pReceiver)) {
+      snapshotReceiverForceStop(pReceiver);
+    }
+
     snapshotReceiverStart(pReceiver, pMsg);  // set start-time same with sender
   }
 
-- 
GitLab