Skip to content
Snippets Groups Projects
Commit dcf5c80c authored by Sören Henning's avatar Sören Henning
Browse files

Enhance log statement in CU2

parent 73536b95
Branches
Tags
1 merge request!90Migrate Flink benchmark implementation
Pipeline #2216 canceled
...@@ -133,9 +133,7 @@ public class HistoryServiceFlinkJob { ...@@ -133,9 +133,7 @@ public class HistoryServiceFlinkJob {
}).name("map") }).name("map")
.addSink(kafkaSink).name("[Kafka Producer] Topic: " + outputTopic); .addSink(kafkaSink).name("[Kafka Producer] Topic: " + outputTopic);
if (LOGGER.isInfoEnabled()) { LOGGER.info("Execution plan: {}", env.getExecutionPlan());
LOGGER.info("Execution Plan: " + env.getExecutionPlan());
}
try { try {
env.execute(applicationId); env.execute(applicationId);
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment