Re: Null Pointer Exception in tests but only in COLLECTION mode

2015-11-25 Thread Maximilian Michels
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

Re: Null Pointer Exception in tests but only in COLLECTION mode

2015-11-24 Thread Martin Junghanns
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

Re: Null Pointer Exception in tests but only in COLLECTION mode

2015-11-24 Thread Maximilian Michels
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

Re: Null Pointer Exception in tests but only in COLLECTION mode

2015-11-22 Thread Martin Junghanns
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

Null Pointer Exception in tests but only in COLLECTION mode

2015-11-20 Thread André Petermann
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