Hi Martin,
Great. Thanks for the fix!
Cheers,
Max
On Tue, Nov 24, 2015 at 7:40 PM, Martin Junghanns
wrote:
> Hi Max,
>
> fixed in https://github.com/apache/flink/pull/1396
>
> Best,
> Martin
>
>
> On 24.11.2015 13:46, Maximilian Michels wrote:
>>
>> Hi André, hi Martin,
>>
>> This looks very mu
Hi Max,
fixed in https://github.com/apache/flink/pull/1396
Best,
Martin
On 24.11.2015 13:46, Maximilian Michels wrote:
Hi André, hi Martin,
This looks very much like a bug. Martin, I would be happy if you
opened a JIRA issue.
Thanks,
Max
On Sun, Nov 22, 2015 at 12:27 PM, Martin Junghanns
w
Hi André, hi Martin,
This looks very much like a bug. Martin, I would be happy if you
opened a JIRA issue.
Thanks,
Max
On Sun, Nov 22, 2015 at 12:27 PM, Martin Junghanns
wrote:
> Hi,
>
> What he meant was MultipleProgramsTestBase, not FlinkTestBase.
>
> I debugged this a bit.
>
> The NPE is thr
Hi,
What he meant was MultipleProgramsTestBase, not FlinkTestBase.
I debugged this a bit.
The NPE is thrown in
https://github.com/apache/flink/blob/master/flink-java/src/main/java/org/apache/flink/api/java/operators/AggregateOperator.java#L296
since current can be null if the input iterator i
Hi all,
during a workflow, a data set may run empty, e.g., because of a join
without matches.
We're using FlinkTestBase and found out, that aggregate functions on
empty data sets work fine in CLUSTER execution mode but cause a Null
Pointer Exception at AggregateOperator$AggregatingUdf in COL