Search code examples
apache-flinkflink-streaming

Is there a way to get the task manager id of the flink taskmanagers


I want to get the integral id / hash id of task manager and report metrics using that.


Solution

  • Finally I got the solution by getting YARN application container ID for each task manager was running into.

    The container id's suits my purpose, thanks for all your insights though.