From a0fd56c84f539ce6c1bc65827c03de368bda675a Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Tue, 22 Aug 2023 10:48:15 +0800 Subject: [PATCH] fix invalid cmp --- source/libs/stream/src/streamMeta.c | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/source/libs/stream/src/streamMeta.c b/source/libs/stream/src/streamMeta.c index 11574e6d70..f4d990de4c 100644 --- a/source/libs/stream/src/streamMeta.c +++ b/source/libs/stream/src/streamMeta.c @@ -93,7 +93,7 @@ SStreamMeta* streamMetaOpen(const char* path, void* ahandle, FTaskExpand expandF taosHashInit(64, taosGetDefaultHashFunction(TSDB_DATA_TYPE_BINARY), false, HASH_ENTRY_LOCK); pMeta->chkpSaved = taosArrayInit(4, sizeof(int64_t)); pMeta->chkpInUse = taosArrayInit(4, sizeof(int64_t)); - pMeta->chkpCap = 8; + pMeta->chkpCap = 2; taosInitRWLatch(&pMeta->chkpDirLock); int64_t chkpId = streamGetLatestCheckpointId(pMeta); @@ -142,11 +142,11 @@ int32_t streamMetaReopen(SStreamMeta* pMeta, int64_t chkpId) { pMeta->streamBackendRid = -1; pMeta->streamBackend = NULL; - char* defaultPath = taosMemoryCalloc(1, strlen(pMeta->path) + 64); + char* defaultPath = taosMemoryCalloc(1, strlen(pMeta->path) + 128); sprintf(defaultPath, "%s%s%s", pMeta->path, TD_DIRSEP, "state"); taosRemoveDir(defaultPath); - char* newPath = taosMemoryCalloc(1, strlen(pMeta->path) + 64); + char* newPath = taosMemoryCalloc(1, strlen(pMeta->path) + 128); sprintf(newPath, "%s%s%s", pMeta->path, TD_DIRSEP, "received"); int32_t code = taosStatFile(newPath, NULL, NULL, NULL); @@ -155,7 +155,7 @@ int32_t streamMetaReopen(SStreamMeta* pMeta, int64_t chkpId) { code = taosRenameFile(newPath, defaultPath); if (code != 0) { terrno = TAOS_SYSTEM_ERROR(code); - qError("vgId:%d failed to rename file, from %s to %s, code:%s", newPath, defaultPath, pMeta->vgId, + qError("vgId:%d failed to rename file, from %s to %s, code:%s", pMeta->vgId, newPath, defaultPath, tstrerror(terrno)); taosMemoryFree(defaultPath);