diff --git a/engine/flink/executor/src/main/scala/pl/touk/nussknacker/engine/process/runner/FlinkStubbedRunner.scala b/engine/flink/executor/src/main/scala/pl/touk/nussknacker/engine/process/runner/FlinkStubbedRunner.scala index 733a5ae2626..b7ef264119e 100644 --- a/engine/flink/executor/src/main/scala/pl/touk/nussknacker/engine/process/runner/FlinkStubbedRunner.scala +++ b/engine/flink/executor/src/main/scala/pl/touk/nussknacker/engine/process/runner/FlinkStubbedRunner.scala @@ -75,12 +75,13 @@ final class FlinkStubbedRunner(modelClassLoader: ModelClassLoader, configuration // and this fallback is to work with a work around for a behaviour added in https://issues.apache.org/jira/browse/FLINK-32265 // see details in pl.touk.nussknacker.engine.flink.test.MiniClusterExecutionEnvironment#execute modelClassLoader.urls match { - case Nil => - ConfigUtils.decodeListFromConfig[String, URL, MalformedURLException]( - configuration, - PipelineOptions.CLASSPATHS, - new URL(_) - ) + // FIXME abr: is it needed? +// case Nil => +// ConfigUtils.decodeListFromConfig[String, URL, MalformedURLException]( +// configuration, +// PipelineOptions.CLASSPATHS, +// new URL(_) +// ) case list => list.asJava } }