Skip to content
Snippets Groups Projects

Migrate Flink benchmark implementation

Merged Sören Henning requested to merge flink-benchmark-migration into master
1 file
+ 1
3
Compare changes
  • Side-by-side
  • Inline
@@ -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);
Loading