diff --git a/internal/datanode/flush_task.go b/internal/datanode/flush_task.go
index 0124e09261..9fd56a2dd3 100644
--- a/internal/datanode/flush_task.go
+++ b/internal/datanode/flush_task.go
@@ -86,7 +86,7 @@ func newTaskInjection(segmentCnt int, pf func(pack *segmentFlushPack)) *taskInje
 	return ti
 }
 
-// Injected returns a chan, which will be closed after pre set segments counts a injected
+// Injected returns a chan, which will be closed after pre set segments counts an injected
 func (ti *taskInjection) Injected() <-chan struct{} {
 	return ti.injected
 }