[NU-1962] Flink test mechanism refactoring: temporary remove classpat…

…h fallback
TouK · Jan 16, 2025 · 40808c0 · 40808c0
1 parent 6504481
commit 40808c0
Showing 1 changed file with 7 additions and 6 deletions.
diff --git a/...xecutor/src/main/scala/pl/touk/nussknacker/engine/process/runner/FlinkStubbedRunner.scala b/...xecutor/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
     }
   }