fix: limit push down error

beb3de85 · Xiaoyu Wang · 6d1621c2 · beb3de85
隐藏空白更改
内联并排

Showing with 2 addition and 0 deletion

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

未找到文件。
--- a/source/libs/planner/src/planSpliter.c
+++ b/source/libs/planner/src/planSpliter.c
@@ -560,6 +560,8 @@ static int32_t stbSplCreateMergeNode(SSplitContext* pCxt, SLogicSubplan* pSubpla
    if (NULL == pMerge->node.pLimit) {
      code = TSDB_CODE_OUT_OF_MEMORY;
    }
+    ((SLimitNode*)pSplitNode->pLimit)->limit += ((SLimitNode*)pSplitNode->pLimit)->offset;
+    ((SLimitNode*)pSplitNode->pLimit)->offset = 0;
  }
  if (TSDB_CODE_SUCCESS == code) {
    if (NULL == pSubplan) {