diff --git a/engine/flink/components/base/src/main/scala/pl/touk/nussknacker/engine/flink/util/transformer/ForEachTransformer.scala b/engine/flink/components/base/src/main/scala/pl/touk/nussknacker/engine/flink/util/transformer/ForEachTransformer.scala index 5161d611224..2c502017d1d 100644 --- a/engine/flink/components/base/src/main/scala/pl/touk/nussknacker/engine/flink/util/transformer/ForEachTransformer.scala +++ b/engine/flink/components/base/src/main/scala/pl/touk/nussknacker/engine/flink/util/transformer/ForEachTransformer.scala @@ -20,7 +20,7 @@ object ForEachTransformer extends CustomStreamTransformer with Serializable { @MethodToInvoke(returnType = classOf[Object]) def invoke( - @ParamName("Elements") elements: LazyParameter[util.Collection[AnyRef]], + @ParamName("Elements") @DefaultValue("{\"item1\", \"item2\"}") elements: LazyParameter[util.Collection[AnyRef]], @OutputVariableName outputVariable: String ): FlinkCustomStreamTransformation with ReturningType = { FlinkCustomStreamTransformation( diff --git a/engine/lite/components/base/src/main/scala/pl/touk/nussknacker/engine/lite/components/ForEachTransformer.scala b/engine/lite/components/base/src/main/scala/pl/touk/nussknacker/engine/lite/components/ForEachTransformer.scala index 7a4dc29bfbe..8c06522b1ef 100644 --- a/engine/lite/components/base/src/main/scala/pl/touk/nussknacker/engine/lite/components/ForEachTransformer.scala +++ b/engine/lite/components/base/src/main/scala/pl/touk/nussknacker/engine/lite/components/ForEachTransformer.scala @@ -15,7 +15,7 @@ object ForEachTransformer extends CustomStreamTransformer { @MethodToInvoke(returnType = classOf[Object]) def invoke( - @ParamName("Elements") elements: LazyParameter[java.util.Collection[Any]], + @ParamName("Elements") @DefaultValue("{\"item1\", \"item2\"}") elements: LazyParameter[java.util.Collection[Any]], @OutputVariableName outputVariable: String ): LiteCustomComponent = { new ForEachTransformerComponent(elements, outputVariable)