diff --git a/engine/flink/components-utils/src/main/scala/pl/touk/nussknacker/engine/flink/util/source/CollectionSource.scala b/engine/flink/components-utils/src/main/scala/pl/touk/nussknacker/engine/flink/util/source/CollectionSource.scala
index c7feadf5014..22d4f19c893 100644
--- a/engine/flink/components-utils/src/main/scala/pl/touk/nussknacker/engine/flink/util/source/CollectionSource.scala
+++ b/engine/flink/components-utils/src/main/scala/pl/touk/nussknacker/engine/flink/util/source/CollectionSource.scala
@@ -21,7 +21,6 @@ import pl.touk.nussknacker.engine.flink.api.timestampwatermark.TimestampWatermar
 
 import scala.jdk.CollectionConverters._
 
-// TODO: remove returnType?
 case class CollectionSource[T: TypeInformation](
     list: List[T],
     timestampAssigner: Option[TimestampWatermarkHandler[T]],