fix: fix rsma writing historical data wal got overwritten by unrelated

SSDatablocks got from streamscan TD- 17958

fix: fix rsma writing historical data wal got overwritten by unrelated
SSDatablocks got from streamscan TD- 17958
344e821e · Ganlin Zhao · 5ddd7536 · 344e821e
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

source/libs/executor/src/timewindowoperator.c source/libs/executor/src/timewindowoperator.c +1 -1

未找到文件。
--- a/source/libs/executor/src/timewindowoperator.c
+++ b/source/libs/executor/src/timewindowoperator.c
@@ -1597,7 +1597,7 @@ static SSDataBlock* doStreamIntervalAgg(SOperatorInfo* pOperator) {
      continue;
    }

-    if (pBlock->info.type == STREAM_NORMAL) {
+    if (pBlock->info.type == STREAM_NORMAL && pBlock->info.version != 0) {
      // set input version
      pTaskInfo->version = pBlock->info.version;
    }