feat: stream interval distributed split

e794d542 · Xiaoyu Wang · f9b74434 · e794d542
隐藏空白更改
内联并排

Showing with 4 addition and 0 deletion

source/libs/planner/src/planSpliter.c source/libs/planner/src/planSpliter.c +4 -0

未找到文件。
--- a/source/libs/planner/src/planSpliter.c
+++ b/source/libs/planner/src/planSpliter.c
@@ -375,6 +375,10 @@ static int32_t stbSplSplitScanNode(SSplitContext* pCxt, SStableSplitInfo* pInfo)
 }

 static int32_t stableSplit(SSplitContext* pCxt, SLogicSubplan* pSubplan) {
+  if (pCxt->pPlanCxt->rSmaQuery) {
+    return TSDB_CODE_SUCCESS;
+  }
+
  SStableSplitInfo info = {0};
  if (!splMatch(pCxt, pSubplan, SPLIT_FLAG_STABLE_SPLIT, (FSplFindSplitNode)stbSplFindSplitNode, &info)) {
    return TSDB_CODE_SUCCESS;