From 73c7e1703392767c13de2a3eba53735eda78111b Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Fri, 15 Dec 2023 18:02:14 +0800 Subject: [PATCH] fix error case --- source/libs/stream/src/streamState.c | 5 +++++ 1 file changed, 5 insertions(+) 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));