From 4fb0f83f070ef2ea03717f4d132b8e31b7741238 Mon Sep 17 00:00:00 2001 From: slzhou Date: Tue, 28 Nov 2023 14:50:50 +0800 Subject: [PATCH] fix: core dump without resetTableListIndex --- include/libs/executor/storageapi.h | 2 +- source/dnode/vnode/src/tsdb/tsdbRead2.c | 3 ++- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/include/libs/executor/storageapi.h b/include/libs/executor/storageapi.h index b45103f94a..2c9b8a4e5e 100644 --- a/include/libs/executor/storageapi.h +++ b/include/libs/executor/storageapi.h @@ -166,7 +166,7 @@ typedef struct { // clang-format off /*-------------------------------------------------new api format---------------------------------------------------*/ typedef enum { - TSD_READER_NOTIFY_DURATION + TSD_READER_NOTIFY_DURATION_START } ETsdReaderNotifyType; typedef union { diff --git a/source/dnode/vnode/src/tsdb/tsdbRead2.c b/source/dnode/vnode/src/tsdb/tsdbRead2.c index d71f1729b6..710a076edc 100644 --- a/source/dnode/vnode/src/tsdb/tsdbRead2.c +++ b/source/dnode/vnode/src/tsdb/tsdbRead2.c @@ -4369,8 +4369,9 @@ static int32_t doTsdbNextDataBlockDurationOrder(STsdbReader* pReader) { if (pReader->notifyFn) { STsdReaderNotifyInfo info = {0}; info.duration.fileSetId = fid; - pReader->notifyFn(TSD_READER_NOTIFY_DURATION, &info, pReader->notifyParam); + pReader->notifyFn(TSD_READER_NOTIFY_DURATION_START, &info, pReader->notifyParam); } + resetTableListIndex(pStatus); } }