fix(query): set start row index for desc scan.

884f9dfe · Haojun Liao · c2f6d4ab · 884f9dfe
隐藏空白更改
内联并排

Showing with 4 addition and 1 deletion

source/dnode/vnode/src/tsdb/tsdbMergeTree.c source/dnode/vnode/src/tsdb/tsdbMergeTree.c +4 -1

未找到文件。
--- a/source/dnode/vnode/src/tsdb/tsdbMergeTree.c
+++ b/source/dnode/vnode/src/tsdb/tsdbMergeTree.c
@@ -501,7 +501,10 @@ bool tLDataIterNextRow(SLDataIter *pIter, const char *idStr) {

    if (iBlockL != pIter->iSttBlk) {
      pBlockData = loadLastBlock(pIter, idStr);
-      pIter->iRow += step;
+      if (pBlockData == NULL) {
+        goto _exit;
+      }
+      pIter->iRow = pIter->backward? pBlockData->nRow-1:0;
    }
  }