diff --git a/theodolite-benchmarks/uc2-application-flink/src/main/java/theodolite/uc2/application/HistoryServiceFlinkJob.java b/theodolite-benchmarks/uc2-application-flink/src/main/java/theodolite/uc2/application/HistoryServiceFlinkJob.java index 9ee64ad2f063f84d0902890e0ad1d2a5b29fd703..714f567c763dc8a5348aae258652371ce3da475f 100644 --- a/theodolite-benchmarks/uc2-application-flink/src/main/java/theodolite/uc2/application/HistoryServiceFlinkJob.java +++ b/theodolite-benchmarks/uc2-application-flink/src/main/java/theodolite/uc2/application/HistoryServiceFlinkJob.java @@ -133,9 +133,7 @@ public class HistoryServiceFlinkJob { }).name("map") .addSink(kafkaSink).name("[Kafka Producer] Topic: " + outputTopic); - if (LOGGER.isInfoEnabled()) { - LOGGER.info("Execution Plan: " + env.getExecutionPlan()); - } + LOGGER.info("Execution plan: {}", env.getExecutionPlan()); try { env.execute(applicationId);