Err, I meant if I'm not wrong *
On Mon, Dec 12, 2016 at 2:02 PM, Matt wrote:
> I just checked with version 1.1.3 and it works fine, the problem is that
> in that version we can't use Kafka 0.10 if I'm not work. Thank you for the
> workaround!
>
> Best,
> Matt
>
> On Mon, Dec 12, 2016 at 1:52 PM,
I just checked with version 1.1.3 and it works fine, the problem is that in
that version we can't use Kafka 0.10 if I'm not work. Thank you for the
workaround!
Best,
Matt
On Mon, Dec 12, 2016 at 1:52 PM, Yassine MARZOUGUI <
y.marzou...@mindlytix.com> wrote:
> Yes, it was suppoed to work. I looke
Yes, it was suppoed to work. I looked into this, and as Chesnay said, this
is a bug in the fold function. I opened an issue in JIRA :
https://issues.apache.org/jira/browse/FLINK-5320, and will fix it very
soon, thank you for reporting it.
In the mean time you can workaround the problem by specifyin
I'm using 1.2-SNAPSHOT, should it work in that version?
On Mon, Dec 12, 2016 at 12:18 PM, Yassine MARZOUGUI <
y.marzou...@mindlytix.com> wrote:
> Hi Matt,
>
> What version of Flink are you using?
> The incremental agregation with fold(ACC, FoldFunction, WindowFunction)
> in a new change that will
Hi Matt,
What version of Flink are you using?
The incremental agregation with fold(ACC, FoldFunction, WindowFunction) in
a new change that will be part of Flink 1.2, for Flink 1.1 the correct way
to perform incrementation aggregations is : apply(ACC, FoldFunction,
WindowFunction) (see the docs for
Hello Matt,
This looks like a bug in the fold() function to me.
I'm adding Timo to the discussion, he can probably shed some light on this.
Regards,
Chesnay
On 12.12.2016 15:13, Matt wrote:
In case this is important, if I remove the WindowFunction, and only
use the FoldFunction it works fine.
In case this is important, if I remove the WindowFunction, and only use the
FoldFunction it works fine.
I don't see what is wrong...
On Mon, Dec 12, 2016 at 10:53 AM, Matt wrote:
> Hi,
>
> I'm following the documentation [1] of window functions with incremental
> aggregations, but I'm getting a
Hi,
I'm following the documentation [1] of window functions with incremental
aggregations, but I'm getting an "input mismatch" error.
The code [2] is almost identical to the one in the documentation, at the
bottom you can find the exact error.
What am I missing? Can you provide a working example
