diff --git a/src/sync/src/syncMain.c b/src/sync/src/syncMain.c
index 436f4de0988aa87836172b8c0284ca767d27c5d8..db100250a8570ec130f89856ce8fa55d493aeb13 100644
--- a/src/sync/src/syncMain.c
+++ b/src/sync/src/syncMain.c
@@ -375,6 +375,8 @@ int32_t syncReconfig(int64_t rid, const SSyncCfg *pNewCfg) {
 }
 
 int32_t syncForwardToPeer(int64_t rid, void *data, void *mhandle, int32_t qtype) {
+  if (rid <= 0) return 0;
+
   SSyncNode *pNode = syncAcquireNode(rid);
   if (pNode == NULL) return 0;