From 8ab545ac775c1d93f57b5d82def947131ee6f1de Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Tue, 18 Jul 2023 01:16:48 +0000 Subject: [PATCH] fillhistory task not trigger checkpoint --- source/dnode/mnode/impl/src/mndStream.c | 3 +++ 1 file changed, 3 insertions(+) diff --git a/source/dnode/mnode/impl/src/mndStream.c b/source/dnode/mnode/impl/src/mndStream.c index 80f657a9a9..d0300c622f 100644 --- a/source/dnode/mnode/impl/src/mndStream.c +++ b/source/dnode/mnode/impl/src/mndStream.c @@ -1093,6 +1093,9 @@ static int32_t mndAddStreamCheckpointToTrans(STrans *pTrans, SStreamObj *pStream int32_t sz = taosArrayGetSize(pLevel); for (int32_t j = 0; j < sz; j++) { SStreamTask *pTask = taosArrayGetP(pLevel, j); + if (pTask->info.fillHistory == 1) { + continue; + } /*A(pTask->info.nodeId > 0);*/ SVgObj *pVgObj = mndAcquireVgroup(pMnode, pTask->info.nodeId); if (pVgObj == NULL) {