Re: Dedup all data in stream

2020-02-12 Thread Akshay Shinde
rg/projects/flink/flink-docs-stable/dev/stream/operators/asyncio.html__;!!GqivPVa7Brio!NE2BACN8q5265oyZUvBg44u3mq7sGn96u3rPtcVbFq9DovpIa1KtilsCXW3mtYofoQw$ > > > On Wed, Feb 12, 2020 at 3:34 AM Akshay Shinde > wrote: >> >> Hi Community >> >> In our Flink job, i

Dedup all data in stream

2020-02-11 Thread Akshay Shinde
Hi Community In our Flink job, in source we are creating our own stream to process n number of objects per 2 minutes. And in process function for each object from generated source stream we are doing some operation which we expect to get finished in 2 minutes. Every 2 minutes we are generatin

NPE in Flink 1.8.0

2019-05-15 Thread Akshay Shinde
) My jobs were working fine with version 1.7.2, now we upgraded our version to 1.8.0 then we are facing this problem. Waiting for your response. -- Regards, Akshay Shinde SMTS, Oracle