diff --git a/src/connector/go b/src/connector/go
new file mode 160000
index 0000000000000000000000000000000000000000..8c58c512b6acda8bcdfa48fdc7140227b5221766
--- /dev/null
+++ b/src/connector/go
@@ -0,0 +1 @@
+Subproject commit 8c58c512b6acda8bcdfa48fdc7140227b5221766
diff --git a/src/system/detail/src/vnodeQueryImpl.c b/src/system/detail/src/vnodeQueryImpl.c
index 7998d4f3a22f5859d926a00f9e693f957d036b7e..e02af78e2470a5233aa19921af6ff76f3849687a 100644
--- a/src/system/detail/src/vnodeQueryImpl.c
+++ b/src/system/detail/src/vnodeQueryImpl.c
@@ -1099,7 +1099,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);