From f9963ecef721188f43e5f6d42603f4265abfe4ea Mon Sep 17 00:00:00 2001 From: hjxilinx Date: Sun, 12 Apr 2020 23:59:25 +0800 Subject: [PATCH] fix bug in commit block decide in function isCacheBlockValid --- src/system/detail/src/vnodeQueryImpl.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/system/detail/src/vnodeQueryImpl.c b/src/system/detail/src/vnodeQueryImpl.c index 4addadd72b..44fa7062db 100644 --- a/src/system/detail/src/vnodeQueryImpl.c +++ b/src/system/detail/src/vnodeQueryImpl.c @@ -1088,7 +1088,7 @@ bool isCacheBlockValid(SQuery *pQuery, SCacheBlock *pBlock, SMeterObj *pMeterObj } SCacheInfo* pCacheInfo = (SCacheInfo*) pMeterObj->pCache; - if (pCacheInfo->commitPoint == pMeterObj->pointsPerBlock && pQuery->slot == pCacheInfo->currentSlot) { + if (pCacheInfo->commitPoint == pMeterObj->pointsPerBlock && pQuery->slot == pCacheInfo->commitSlot) { dWarn("QInfo:%p vid:%d sid:%d id:%s, cache block is committed, ignore. slot:%d first:%d, last:%d, numOfBlocks:%d", GET_QINFO_ADDR(pQuery), pMeterObj->vnode, pMeterObj->sid, pMeterObj->meterId, slot, pQuery->firstSlot, pQuery->currentSlot, pQuery->numOfBlocks); -- GitLab