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,