diff --git a/internal/querynode/data_sync_service.go b/internal/querynode/data_sync_service.go
index de0a21d921..9168abd909 100644
--- a/internal/querynode/data_sync_service.go
+++ b/internal/querynode/data_sync_service.go
@@ -195,6 +195,7 @@ func (dsService *dataSyncService) removePartitionFlowGraph(partitionID UniqueID)
 	delete(dsService.partitionFlowGraphs, partitionID)
 }
 
+// newDataSyncService returns a new dataSyncService
 func newDataSyncService(ctx context.Context,
 	streamingReplica ReplicaInterface,
 	tSafeReplica TSafeReplicaInterface,