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 = _
>
>
> Regards,
>
> Kien
>
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
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.
>
> So I have this class:
>
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 counter:Coun