stream scan checkpoint

e1134423 · liuyao · fa8025f3 · e1134423
隐藏空白更改
内联并排

Showing with 2 addition and 0 deletion

source/libs/executor/src/scanoperator.c source/libs/executor/src/scanoperator.c +2 -0

未找到文件。
--- a/source/libs/executor/src/scanoperator.c
+++ b/source/libs/executor/src/scanoperator.c
@@ -2185,6 +2185,8 @@ FETCH_NEXT_BLOCK:
      pAPI->stateStore.streamStateCommit(pInfo->pState);
      pAPI->stateStore.streamStateDeleteCheckPoint(pInfo->pState, pInfo->twAggSup.maxTs - pInfo->twAggSup.deleteMark);
    }
+    printDataBlock(pBlock, "stream scan ck");
+    return pBlock;
  }

  return NULL;