Fix EntriesNum is not passed in flush task (#15482)

Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
2022-02-09 10:05:46 +08:00 · 2022-02-09 10:05:46 +08:00 · 2263425cde
parent 5bd0de4d81
commit 2263425cde
1 changed files with 1 additions and 0 deletions
--- 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(),
 				},
 			}
 		}