From dcf5c80cd9df9256424ed539c45a1127b1957f4b Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?S=C3=B6ren=20Henning?= <soeren.henning@email.uni-kiel.de>
Date: Tue, 9 Mar 2021 17:57:08 +0100
Subject: [PATCH] Enhance log statement in CU2
---
.../theodolite/uc2/application/HistoryServiceFlinkJob.java | 4 +---
1 file changed, 1 insertion(+), 3 deletions(-)
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 9ee64ad2f..714f567c7 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);
--
GitLab