From 3d532a54a8dfdc375558cc27660cbdd2f6580be6 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Wed, 28 Jun 2023 12:22:27 +0000 Subject: [PATCH] add checkpoint --- source/dnode/vnode/src/tq/tqStreamStateSnap.c | 2 +- source/dnode/vnode/src/tq/tqStreamTaskSnap.c | 6 ++---- 2 files changed, 3 insertions(+), 5 deletions(-) diff --git a/source/dnode/vnode/src/tq/tqStreamStateSnap.c b/source/dnode/vnode/src/tq/tqStreamStateSnap.c index 9223a0c211..0b758d0d22 100644 --- a/source/dnode/vnode/src/tq/tqStreamStateSnap.c +++ b/source/dnode/vnode/src/tq/tqStreamStateSnap.c @@ -45,7 +45,7 @@ int32_t streamStateSnapReaderOpen(STQ* pTq, int64_t sver, int64_t ever, SStreamS pReader->ever = ever; SStreamSnapReader* pSnapReader = NULL; - sprintf(tdir, "%s%s%s", pTq->path, TD_DIRSEP, VNODE_TQ_STREAM); + sprintf(tdir, "%s%s%s%s%s", pTq->path, TD_DIRSEP, VNODE_TQ_STREAM, TD_DIRSEP, "checkpoints"); streamSnapReaderOpen(pTq, sver, ever, tdir, &pSnapReader); pReader->pReaderImpl = pSnapReader; diff --git a/source/dnode/vnode/src/tq/tqStreamTaskSnap.c b/source/dnode/vnode/src/tq/tqStreamTaskSnap.c index 296369a80c..603c972ff9 100644 --- a/source/dnode/vnode/src/tq/tqStreamTaskSnap.c +++ b/source/dnode/vnode/src/tq/tqStreamTaskSnap.c @@ -117,10 +117,10 @@ NextTbl: tdbTbcClose(pReader->pCur); pReader->pos += 1; - code = tdbTbcOpen(taosArrayGetP(pReader->tdbTbList, pReader->pos), &pReader->pCur, NULL); + pPair = taosArrayGet(pReader->tdbTbList, pReader->pos); + code = tdbTbcOpen(pPair->tbl, &pReader->pCur, NULL); tdbTbcMoveToFirst(pReader->pCur); - pPair = taosArrayGet(pReader->tdbTbList, pReader->pos); goto NextTbl; } } @@ -141,8 +141,6 @@ NextTbl: tqInfo("vgId:%d, vnode stream-task snapshot read data vLen:%d", TD_VID(pReader->pTq->pVnode), vLen); - return code; -_exit: return code; _err: tqError("vgId:%d, vnode stream-task snapshot read data failed since %s", TD_VID(pReader->pTq->pVnode),