Skip to content
Snippets Groups Projects

Unify logging among all streaming engines

Merged Sören Henning requested to merge unify-logging into main
Files
7
@@ -64,7 +64,7 @@ public final class HistoryServiceFlinkJob extends AbstractFlinkService {
.map(t -> {
final String key = t.f0;
final String value = t.f1.toString();
LOGGER.info("{}: {}", key, value); // TODO align implementations
// LOGGER.info("{}: {}", key, value);
return new Tuple2<>(key, value);
}).name("map").returns(Types.TUPLE(Types.STRING, Types.STRING))
.addSink(kafkaSink).name("[Kafka Producer] Topic: " + outputTopic);
Loading