[td-3294]fix bug found by regression test.

45acc9d3 · Haojun Liao · 4eeb83d1 · 45acc9d3
显示空白变更内容
内联并排

Showing with 1 addition and 1 deletion

src/query/src/qExecutor.c src/query/src/qExecutor.c +1 -1

未找到文件。
--- a/src/query/src/qExecutor.c
+++ b/src/query/src/qExecutor.c
@@ -4564,7 +4564,7 @@ static SSDataBlock* doOffset(void* param) {

    if (pRuntimeEnv->currentOffset == 0) {
      return pBlock;
-    } else if (pRuntimeEnv->currentOffset > pBlock->info.rows) {
+    } else if (pRuntimeEnv->currentOffset >= pBlock->info.rows) {
      pRuntimeEnv->currentOffset -= pBlock->info.rows;
    } else {
      int32_t remain = (int32_t)(pBlock->info.rows - pRuntimeEnv->currentOffset);