RE: RichInputFormat working differently in eclipse and in flink cluster

2018-11-11 Thread Teena Kappen // BPRISE
Hi Till, We are using 1.4.0. We have not tried this any other releases. We will try this on 1.6.2 and see what happens. Thank you. Regards, Teena From: Till Rohrmann Sent: 07 November 2018 20:23 To: Teena Kappen // BPRISE Cc: user Subject: Re: RichInputFormat working differently in eclipse

Re: RichInputFormat working differently in eclipse and in flink cluster

2018-11-07 Thread Till Rohrmann
Hi Teena, which Flink version are you using? Have you tried whether this happens with the latest release 1.6.2 as well? Cheers, Till On Fri, Oct 26, 2018 at 1:17 PM Teena Kappen // BPRISE < teena.kap...@bprise.com> wrote: > Hi all, > > > > I have implemented RichInputFormat for reading result

RichInputFormat working differently in eclipse and in flink cluster

2018-10-26 Thread Teena Kappen // BPRISE
Hi all, I have implemented RichInputFormat for reading result of aggregation queries in Elasticsearch. There are around 10 buckets, which are of type json array. Note: This is one time response. My idea here is to iterate these arrays in parallel. Here is the pseudo code. public void