I have multiple sources but with distinct names and UIDs. More information about my execution environment:
Flink Version: 1.4.2 bundled with hadoop 2.8 State backend: Hadoop 2.8 Job compiled for version 1.4.2 using the Scala version libs from Scala version 2.11. Am using the com.github.davidb to export the metrics to influxdb as exemplified here: https://github.com/jgrier/flink-stuff/tree/master/flink-influx-reporter but recompiled for version 1.4.2. ----- Best Regards, Pedro Chaves -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/