Re: [Docs] Can't add metrics to RichFilterFunction

Thanks for reporting the issue. I've filed FLINK-8278 [1] to fix the issue. Best, Fabian [1] https://issues.apache.org/jira/browse/FLINK-8278 2017-12-14 14:04 GMT+01:00 Kien Truong : > That syntax is incorrect, should be. > > @transient private var counter:Counter = _

Re: [Docs] Can't add metrics to RichFilterFunction

That syntax is incorrect, should be. @transient private var counter:Counter = _ Regards, Kien On 12/14/2017 8:03 PM, Julio Biason wrote: @transient private var counter:Counter

Re: [Docs] Can't add metrics to RichFilterFunction

Oh, obviously, code is Scala. Also we are using Flink 1.4.0 and flink-metrics-core-1.4-SNAPSHOT. On Thu, Dec 14, 2017 at 10:56 AM, Julio Biason wrote: > Hello, > > I'm trying to add a metric to a filter function, but following the example > in the docs is not working. >

[Docs] Can't add metrics to RichFilterFunction

Hello, I'm trying to add a metric to a filter function, but following the example in the docs is not working. So I have this class: ``` class LogBrokenFilter extends RichFilterFunction[LineData] { private val logger = LoggerFactory.getLogger(this.getClass) @transient private var