From a9e4a0969e7ac9af9a44df9634f8c91ba90f1500 Mon Sep 17 00:00:00 2001
From: Arek Burdach <arek.burdach@gmail.com>
Date: Mon, 20 Jan 2025 12:10:45 +0100
Subject: [PATCH] FlinkProcessVerifier: test fix attempt: creating env before
 mini cluster

---
 .../management/testsmechanism/FlinkProcessVerifier.scala    | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/engine/flink/management/src/main/scala/pl/touk/nussknacker/engine/management/testsmechanism/FlinkProcessVerifier.scala b/engine/flink/management/src/main/scala/pl/touk/nussknacker/engine/management/testsmechanism/FlinkProcessVerifier.scala
index 46e3f1f2c48..3ef087e4222 100644
--- a/engine/flink/management/src/main/scala/pl/touk/nussknacker/engine/management/testsmechanism/FlinkProcessVerifier.scala
+++ b/engine/flink/management/src/main/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,