diff --git a/internal/datanode/flush_manager.go b/internal/datanode/flush_manager.go
index 488ad7bca377bd179be3eb9b253b066304f971fd..cccba50b527f8d44c250f9322100440d7d98f5ee 100644
--- a/internal/datanode/flush_manager.go
+++ b/internal/datanode/flush_manager.go
@@ -247,7 +247,7 @@ type rendezvousFlushManager struct {
 	dropHandler dropHandler
 }
 
-// getFlushQueue gets or creates a orderFlushQueue for segment id if not found
+// getFlushQueue gets or creates an orderFlushQueue for segment id if not found
 func (m *rendezvousFlushManager) getFlushQueue(segmentID UniqueID) *orderFlushQueue {
 	newQueue := newOrderFlushQueue(segmentID, m.notifyFunc)
 	actual, _ := m.dispatcher.LoadOrStore(segmentID, newQueue)