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);
       }
     }