Fix checkpoint will not update after delete and compact (#21495)

Signed-off-by: cai.zhang <cai.zhang@zilliz.com>
2023-01-04 10:15:34 +08:00 · 2023-01-04 10:15:34 +08:00 · 225c2b7113
parent dc94fb61ac
commit 225c2b7113
1 changed files with 1 additions and 3 deletions
--- a/internal/datanode/flow_graph_delete_node.go
+++ b/internal/datanode/flow_graph_delete_node.go
@ -93,9 +93,7 @@ func (dn *deleteNode) Operate(in []Msg) []Msg {
 	}

 	// update compacted segment before operation
-	if len(fgMsg.deleteMessages) > 0 || len(fgMsg.segmentsToSync) > 0 {
-		dn.updateCompactedSegments()
-	}
+	dn.updateCompactedSegments()

 	// process delete messages
 	var segIDs []UniqueID