Thanks, this is exactly what I was looking for.
Cheers,
Omar.
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/TaskManager-information-during-runtime-tp7655p7665.html
Sent from the Apache Flink User Mailing List archive. mailing list archive
Hi,
you can implement a RichSourceFunction. With this you can also implement
open() and close() methods that get called when your source is started on
the worker node and closed respectively. In there, you could determine the
hostname and send it to some centralized service so that it knows the
hos
