Re: How to get taskmanager hostname and port on runtime

2018-09-17 Thread 郑舒力
Hi, Thanks for your reply. port means akka tcp port. Because I want to unique identify a taskmanager. container_id is an other choice. Kafka metric reporter implement kafka interface, that is not a flink MetricReporter. So i can’t get flink runtime info directly. > 在 2018年9月13日,下午4:25,Dawid W

Re: How to get taskmanager hostname and port on runtime

2018-09-13 Thread Dawid Wysakowicz
Hi, For the hostname, by default identifier for metrics scoped to taskmanager contain its hostname. You can read more about metrics scope here[1]. What do you mean by port? Which port would you like to report? [1] https://ci.apache.org/projects/flink/flink-docs-release-1.6/monitoring/metrics.ht

How to get taskmanager hostname and port on runtime

2018-09-12 Thread 郑舒力
Hello community, Is there a way to get taskmanager hostname and port on runtime? I’d like to implement a kafka metric reporter, reporter should be able to report the taskmanager hostname and port to monitoring system. Thanks.