diff --git a/source/libs/stream/src/streamState.c b/source/libs/stream/src/streamState.c
index 6d810f9c11..776a9db522 100644
--- a/source/libs/stream/src/streamState.c
+++ b/source/libs/stream/src/streamState.c
@@ -1117,6 +1117,11 @@ int32_t streamStateDeleteCheckPoint(SStreamState* pState, TSKEY mark) {
 void streamStateReloadInfo(SStreamState* pState, TSKEY ts) { streamFileStateReloadInfo(pState->pFileState, ts); }
 
 void streamStateCopyBackend(SStreamState* src, SStreamState* dst) {
+  dst->pFileState = src->pFileState;
+  dst->parNameMap = src->parNameMap;
+  dst->number = src->number;
+  dst->taskId = src->taskId;
+  dst->streamId = src->streamId;
   if (dst->pTdbState == NULL) {
     dst->pTdbState = taosMemoryCalloc(1, sizeof(STdbState));
     dst->pTdbState->pOwner = taosMemoryCalloc(1, sizeof(SStreamTask));