From 2263425cde41623520fd5fca9efa78484e2ed979 Mon Sep 17 00:00:00 2001
From: congqixia <congqi.xia@zilliz.com>
Date: Wed, 9 Feb 2022 10:05:46 +0800
Subject: [PATCH] Fix EntriesNum is not passed in flush task (#15482)

Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
---
 internal/datanode/flush_task.go | 1 +
 1 file changed, 1 insertion(+)

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(),
 				},
 			}
 		}