From 82629c26581708c4c0674604bd9a9570a20f8609 Mon Sep 17 00:00:00 2001 From: slzhou Date: Fri, 1 Dec 2023 15:11:43 +0800 Subject: [PATCH] fix: notify when there are no memory pre fileset --- source/dnode/vnode/src/tsdb/tsdbRead2.c | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/source/dnode/vnode/src/tsdb/tsdbRead2.c b/source/dnode/vnode/src/tsdb/tsdbRead2.c index 853d0d7374..ecc1351698 100644 --- a/source/dnode/vnode/src/tsdb/tsdbRead2.c +++ b/source/dnode/vnode/src/tsdb/tsdbRead2.c @@ -2514,6 +2514,15 @@ static void prepareDurationForNextFileSet(STsdbReader* pReader) { if (pReader->status.bProcMemPreFileset) { resetTableListIndex(&pReader->status); } + + if (!pReader->status.bProcMemFirstFileset) { + if (pReader->notifyFn) { + STsdReaderNotifyInfo info = {0}; + info.duration.fileSetId = fid; + pReader->notifyFn(TSD_READER_NOTIFY_DURATION_START, &info, pReader->notifyParam); + } + } + pReader->status.prevFilesetStartKey = winFid.skey; pReader->status.prevFilesetEndKey = winFid.ekey; }