diff --git a/source/libs/sync/src/syncEnv.c b/source/libs/sync/src/syncEnv.c
index 4d4cb8ab69..5b8acfa5ef 100644
--- a/source/libs/sync/src/syncEnv.c
+++ b/source/libs/sync/src/syncEnv.c
@@ -71,7 +71,7 @@ int64_t syncNodeAdd(SSyncNode *pNode) {
   if (pNode->rid < 0) return -1;
 
   sDebug("vgId:%d, sync rid:%" PRId64 " is added to rsetId:%d", pNode->vgId, pNode->rid, gNodeRefId);
-  return 0;
+  return pNode->rid;
 }
 
 void syncNodeRemove(SSyncNode *pNode) {