From 4601e67e672ea499b356770736a89a594b42ddd8 Mon Sep 17 00:00:00 2001 From: Liu Jicong Date: Fri, 30 Dec 2022 16:59:48 +0800 Subject: [PATCH 1/2] fix: reset stream status when load from disk --- source/libs/stream/src/streamMeta.c | 1 + 1 file changed, 1 insertion(+) diff --git a/source/libs/stream/src/streamMeta.c b/source/libs/stream/src/streamMeta.c index afad78c5e5..2b22a4ed29 100644 --- a/source/libs/stream/src/streamMeta.c +++ b/source/libs/stream/src/streamMeta.c @@ -294,6 +294,7 @@ int32_t streamLoadTasks(SStreamMeta* pMeta) { tdbTbcClose(pCur); return -1; } + pTask->taskStatus = TASK_STATUS__NORMAL; } tdbFree(pKey); From 095c6d39ca1f820582d7eece893e2905698b8340 Mon Sep 17 00:00:00 2001 From: Liu Jicong Date: Fri, 30 Dec 2022 17:30:02 +0800 Subject: [PATCH 2/2] reset param --- source/libs/stream/src/streamState.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/source/libs/stream/src/streamState.c b/source/libs/stream/src/streamState.c index 96c86be94d..6670bf463e 100644 --- a/source/libs/stream/src/streamState.c +++ b/source/libs/stream/src/streamState.c @@ -107,7 +107,7 @@ static inline int stateKeyCmpr(const void* pKey1, int kLen1, const void* pKey2, } SStreamState* streamStateOpen(char* path, SStreamTask* pTask, bool specPath, int32_t szPage, int32_t pages) { - szPage = szPage < 0 ? (16 * 1024) : szPage; + szPage = szPage < 0 ? 4096 : szPage; pages = pages < 0 ? 256 : pages; SStreamState* pState = taosMemoryCalloc(1, sizeof(SStreamState)); if (pState == NULL) {