xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix(stream): update the current processing version.

This commit is contained in:
Haojun Liao 2023-10-07 09:07:44 +08:00
parent 798f559b62
commit 011627d50a
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
source/libs/stream/src/streamMeta.c
View File

@ -899,7 +899,7 @@ void metaHbToMnode(void* param, void* tmrId) {
// entry.outputRate = entry.outputQUsed*100.0/STREAM_TASK_QUEUE_CAPACITY_IN_SIZE;
if ((*pTask)->exec.pWalReader != NULL) {
entry.offset = walReaderGetCurrentVer((*pTask)->exec.pWalReader);
entry.offset = (*pTask)->chkInfo.nextProcessVer;
walReaderValidVersionRange((*pTask)->exec.pWalReader, &entry.verStart, &entry.verEnd);
}