metric does not display on web

2019-04-18 Thread sora
Hi all, I am trying to monitor my flink application, so I add two metric in my application. But I can not see any information on the web. The metric tab says "No metrics available". Do I miss any config? My flink version: 1.7.2 My example code: def main(args: Array[String]) { val env = Stream

Flink: How to use zookeeper when deployed in k8s?

2019-04-01 Thread sora
Hello, I encountered a problem when deploying flink to k8s. When high-availability: zookeeper in flink-conf.yaml is set, a random port will be used instead of the config port. But this port is not exposed in k8s, and all taskmanager can not connect to jobmanager. How can I solve this? One solut