Hi,
could you please go into more detail about the input and what the expected
output is. And then also what the output is with both apply() and reduce()?
With this we might be able to figure it out together.
Cheers,
Aljoscha
On Mon, 24 Oct 2016 at 18:11 Sendoh wrote:
> Hi Flink users,
>
> I s
Hi Flink users,
I saw a strange behavior that data are missing in reduce() but apply()
doesn't, and when using 1.0.3 we don't see this behavior, and we see this in
1.1.3. Losing data means we don't see any event in the keys assigned, not
the count of events.
The code is as follows.
DataStream> s
