From 57608e7fff1d521504c0b8c258a43f33544f6084 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Wed, 30 Aug 2023 17:12:37 +0800 Subject: [PATCH] fix merge error --- source/libs/stream/src/streamMeta.c | 16 +--------------- 1 file changed, 1 insertion(+), 15 deletions(-) diff --git a/source/libs/stream/src/streamMeta.c b/source/libs/stream/src/streamMeta.c index 98e7bd8a51..f1fb97bc64 100644 --- a/source/libs/stream/src/streamMeta.c +++ b/source/libs/stream/src/streamMeta.c @@ -113,7 +113,7 @@ SStreamMeta* streamMetaOpen(const char* path, void* ahandle, FTaskExpand expandF } int32_t len = strlen(path) + 64; - char* tpath = taosMemoryCalloc(1, len); + char* tpath = taosMemoryCalloc(1, len); sprintf(tpath, "%s%s%s", path, TD_DIRSEP, "stream"); pMeta->path = tpath; @@ -122,13 +122,6 @@ SStreamMeta* streamMetaOpen(const char* path, void* ahandle, FTaskExpand expandF goto _err; } - sprintf(tpath, "%s/%s", pMeta->path, "checkpoints"); - code = taosMulModeMkDir(tpath, 0755, false); - if (code != 0) { - terrno = TAOS_SYSTEM_ERROR(code); - goto _err; - } - if (tdbTbOpen("task.db", STREAM_TASK_KEY_LEN, -1, NULL, pMeta->db, &pMeta->pTaskDb, 0) < 0) { goto _err; } @@ -165,13 +158,6 @@ SStreamMeta* streamMetaOpen(const char* path, void* ahandle, FTaskExpand expandF int64_t* pRid = taosMemoryMalloc(sizeof(int64_t)); *pRid = pMeta->rid; - sprintf(tpath, "%s/%s", pMeta->path, "state"); - code = taosMulModeMkDir(tpath, 0755, false); - if (code != 0) { - terrno = TAOS_SYSTEM_ERROR(code); - goto _err; - } - metaRefMgtAdd(pMeta->vgId, pRid); pMeta->hbInfo.hbTmr = taosTmrStart(metaHbToMnode, META_HB_CHECK_INTERVAL, pRid, streamEnv.timer);