FlinkProcessVerifier: test fix attempt: creating env before mini cluster

TouK · Jan 20, 2025 · a9e4a09 · a9e4a09
1 parent e286efc
commit a9e4a09
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/...ain/scala/pl/touk/nussknacker/engine/management/testsmechanism/FlinkProcessVerifier.scala b/...ain/scala/pl/touk/nussknacker/engine/management/testsmechanism/FlinkProcessVerifier.scala
@@ -35,9 +35,11 @@ class FlinkProcessVerifier(modelData: ModelData) extends LazyLogging {
     try {
       logger.info(s"Starting to verify $processId")
       // TODO: reuse a single mini cluster between each verifications
+      val env = TestsMechanismStreamExecutionEnvironmentFactory.createStreamExecutionEnvironment(
+        parallelism,
+        new Configuration()
+      )
       Using(TestsMechanismMiniClusterFactory.createConfiguredMiniCluster(parallelism)) { miniCluster =>
-        val env = TestsMechanismStreamExecutionEnvironmentFactory.createStreamExecutionEnvironment(parallelism, new Configuration())
-
         methodInvoker.invokeStaticMethod(
           miniCluster,
           env,