fix transfer error

source/dnode/vnode/src/tq/tqStreamStateSnap.c

@@ -159,7 +159,7 @@ int32_t streamStateSnapWriterClose(SStreamStateWriter* pWriter, int8_t rollback)
   int32_t code = 0;
   tqDebug("vgId:%d, vnode stream-state snapshot writer closed", TD_VID(pWriter->pTq->pVnode));
   code = streamSnapWriterClose(pWriter->pWriterImpl, rollback);
-  taosMemoryFree(pWriter);
+
   return code;
 }
 int32_t streamStateRebuildFromSnap(SStreamStateWriter* pWriter, int64_t chkpId) {
@@ -167,6 +167,7 @@ int32_t streamStateRebuildFromSnap(SStreamStateWriter* pWriter, int64_t chkpId)
   if (code == 0) {
     code = streamStateLoadTasks(pWriter);
   }
+  taosMemoryFree(pWriter);
   return code;
 }
 

source/dnode/vnode/src/vnd/vnodeSnapshot.c

@@ -420,6 +420,7 @@ int32_t vnodeSnapWriterClose(SVSnapWriter *pWriter, int8_t rollback, SSnapshot *
     if (code) goto _exit;
 
     code = streamStateRebuildFromSnap(pWriter->pStreamStateWriter, 0);
+    pWriter->pStreamStateWriter = NULL;
     if (code) goto _exit;
   }
 

source/libs/stream/src/streamMeta.c

@@ -153,7 +153,7 @@ int32_t streamMetaReopen(SStreamMeta* pMeta, int64_t chkpId) {
   }
 
   // close stream backend
-  streamBackendCleanup(pMeta->streamBackend);
+  // streamBackendCleanup(pMeta->streamBackend);
   taosRemoveRef(streamBackendId, pMeta->streamBackendRid);
   pMeta->streamBackendRid = -1;
   pMeta->streamBackend = NULL;