fix update bug

2b1dc53a · Hongze Cheng · 3d2a77ea · 2b1dc53a
隐藏空白更改
内联并排

Showing with 5 addition and 1 deletion

src/tsdb/src/tsdbRead.c src/tsdb/src/tsdbRead.c +5 -1

未找到文件。
--- a/src/tsdb/src/tsdbRead.c
+++ b/src/tsdb/src/tsdbRead.c
@@ -1321,7 +1321,11 @@ static void doMergeTwoLevelData(STsdbQueryHandle* pQueryHandle, STableCheckInfo*
        assert(end != -1);

        if (tsArray[end] == key) { // the value of key in cache equals to the end timestamp value, ignore it
-          moveToNextRowInMem(pCheckInfo);
+          if (!pCfg->update) {
+            moveToNextRowInMem(pCheckInfo);
+          } else {
+            end -= step;
+          }
        }

        int32_t qstart = 0, qend = 0;