Re: SingleOutputStreamOperator addsink Error

2017-06-08 Thread G.S.Vijay Raajaa
That's right. Jackson and Gson similar naming convention. Thanks for the quick catch. Regards, Vijay Raajaa GS On Fri, Jun 9, 2017 at 1:59 AM, Ted Yu wrote: > bq. new SinkFunction(){ > > Note the case in JsonObject. It should be JSONObject > > FYI > > On Thu, Jun 8, 2017 at 1:27 PM, G.S.Vijay

Re: SingleOutputStreamOperator addsink Error

2017-06-08 Thread Ted Yu
bq. new SinkFunction(){ Note the case in JsonObject. It should be JSONObject FYI On Thu, Jun 8, 2017 at 1:27 PM, G.S.Vijay Raajaa wrote: > Hi, > > I am trying to pass the SingleOutputStreamOperator to a custom sink. I am > getting an error while implementing the same. > > Code snippet: > > Sin