No; you can name operators like this:
stream.map(<mapFunction>).name("MyUniqueMapFunctionName")
On 16.05.2017 14:50, rizhashmi wrote:
thanks for your reply
*latency* metrics appear to be pushed by AbstractStreamOperator.java
latencyGauge = this.metrics.gauge("latency", new LatencyGauge(historySize));
does it mean this methods need to be override?
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Group-already-contains-a-Metric-with-the-name-latency-tp13157p13164.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
