From 1275c048158dcbc64c8deee99cbfc3dc3109eba9 Mon Sep 17 00:00:00 2001 From: Kuba Nowakowski Date: Sun, 22 Mar 2026 16:22:34 +0100 Subject: [PATCH] ForEach: add default value {"item1", "item2"} for Elements parameter Prevents immediate validation error when node is added before user has a chance to fill in the field. --- .../engine/flink/util/transformer/ForEachTransformer.scala | 2 +- .../nussknacker/engine/lite/components/ForEachTransformer.scala | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) 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)