fix(stream): read preversion data with delete many times

012dd30b · 54liuyao · 442f8978 · 012dd30b
隐藏空白更改
内联并排

Showing with 2 addition and 1 deletion

source/dnode/vnode/src/tsdb/tsdbRead.c source/dnode/vnode/src/tsdb/tsdbRead.c +2 -1

未找到文件。
--- a/source/dnode/vnode/src/tsdb/tsdbRead.c
+++ b/source/dnode/vnode/src/tsdb/tsdbRead.c
@@ -2907,7 +2907,8 @@ bool hasBeenDropped(const SArray* pDelList, int32_t* index, TSDBKEY* pKey, int32
            continue;
          }

-          if (pCurrent->ts <= pKey->ts && pNext->ts >= pKey->ts && pCurrent->version >= pKey->version) {
+          if (pCurrent->ts <= pKey->ts && pNext->ts >= pKey->ts && pCurrent->version >= pKey->version &&
+              pVerRange->maxVer >= pCurrent->version) {
            return true;
          }
        }