fix(stream): fix the compatible issue when the fill-history exists.

2024-02-23 09:12:27 +08:00 · 2024-02-23 09:12:27 +08:00 · d8ffa65b62
parent 3498763a1b
commit d8ffa65b62
1 changed files with 1 additions and 0 deletions
--- a/source/libs/stream/src/streamTask.c
+++ b/source/libs/stream/src/streamTask.c
@ -509,6 +509,7 @@ int32_t streamTaskInit(SStreamTask* pTask, SStreamMeta* pMeta, SMsgCb* pMsgCb, i
          if (pRange->range.minVer == 0) {
            pChkInfo->checkpointVer = 0;
            pChkInfo->processedVer = 0;
+            pChkInfo->nextProcessVer = 1;
            stDebug("s-task:%s update the processedVer to 0 from -1 due to compatible purpose", pTask->id.idStr);
          }
        }