diff --git a/flink114/manager/src/it/scala/pl/touk/nussknacker/engine/management/streaming/Flink114StreamingDeploymentManagerSpec.scala b/flink114/manager/src/it/scala/pl/touk/nussknacker/engine/management/streaming/Flink114StreamingDeploymentManagerSpec.scala index c2837f2..b794b27 100644 --- a/flink114/manager/src/it/scala/pl/touk/nussknacker/engine/management/streaming/Flink114StreamingDeploymentManagerSpec.scala +++ b/flink114/manager/src/it/scala/pl/touk/nussknacker/engine/management/streaming/Flink114StreamingDeploymentManagerSpec.scala @@ -6,7 +6,7 @@ import pl.touk.nussknacker.engine.util.config.ScalaMajorVersionConfig class Flink114StreamingDeploymentManagerSpec extends CommonFlinkStreamingDeploymentManagerSpec { override protected def classPath: String = - s"./flink114/model/target/scala-${ScalaMajorVersionConfig.scalaMajorVersion}/flink114-model-assembly.jar" + s"./flink114/model/target/scala-${ScalaMajorVersionConfig.scalaMajorVersion}/nussknacker-flink-1-14-model-assembly.jar" override protected def deploymentManagerProvider: FlinkStreamingDeploymentManagerProvider = new FlinkStreamingDeploymentManagerProvider() diff --git a/flink116/manager/src/it/scala/pl/touk/nussknacker/engine/management/streaming/Flink116StreamingDeploymentManagerSpec.scala b/flink116/manager/src/it/scala/pl/touk/nussknacker/engine/management/streaming/Flink116StreamingDeploymentManagerSpec.scala index 57eeaa9..3745f00 100644 --- a/flink116/manager/src/it/scala/pl/touk/nussknacker/engine/management/streaming/Flink116StreamingDeploymentManagerSpec.scala +++ b/flink116/manager/src/it/scala/pl/touk/nussknacker/engine/management/streaming/Flink116StreamingDeploymentManagerSpec.scala @@ -6,7 +6,7 @@ import pl.touk.nussknacker.engine.util.config.ScalaMajorVersionConfig class Flink116StreamingDeploymentManagerSpec extends CommonFlinkStreamingDeploymentManagerSpec { override protected def classPath: String = - s"./flink116/model/target/scala-${ScalaMajorVersionConfig.scalaMajorVersion}/flink116-model-assembly.jar" + s"./flink116/model/target/scala-${ScalaMajorVersionConfig.scalaMajorVersion}/nussknacker-flink-1-16-model-assembly.jar" override protected def deploymentManagerProvider: FlinkStreamingDeploymentManagerProvider = new FlinkStreamingDeploymentManagerProvider()