diff --git a/internal/datanode/flush_task.go b/internal/datanode/flush_task.go index 9fd56a2dd3..2abb2909b9 100644 --- a/internal/datanode/flush_task.go +++ b/internal/datanode/flush_task.go @@ -153,6 +153,7 @@ func (t *flushTaskRunner) runFlushDel(task flushDeleteTask, deltaLogs *DelDataBu LogPath: deltaLogs.GetLogPath(), TimestampFrom: deltaLogs.GetTimestampFrom(), TimestampTo: deltaLogs.GetTimestampTo(), + EntriesNum: deltaLogs.GetEntriesNum(), }, } }