Re: Question about Flink Metrics

2017-09-26 Thread Hai Zhou
Hi Tony, you can consider implementing a reporter, use a trick to convert the flink's metrics to the structure that suits your needs. This is just my personal practice, hoping to help you. Cheers, Hai Zhou > 在 2017年9月26日,17:49,Tony Wei 写道: > > Hi, > >

Re: [DISCUSS] Dropping Scala 2.10

2017-09-20 Thread Hai Zhou
+1 > 在 2017年9月19日,17:56,Aljoscha Krettek 写道: > > Hi, > > Talking to some people I get the impression that Scala 2.10 is quite outdated > by now. I would like to drop support for Scala 2.10 and my main motivation is > that this would allow us to drop our custom Flakka build of Akka that we use

Re: IllegalArgumentException when using elasticsearch as a sink

2017-08-14 Thread Hai Zhou
I would like to ask what is “PB object”? Thanks. Hai Zhou > 在 2017年8月15日,09:53,mingleizhang <18717838...@163.com> 写道: > > Thanks, Nico. I tried flink1.3.2. Works now. Thank you very much! I think > there should be something else to cause this error to happen. Not only t