flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From André Petermann <peterm...@informatik.uni-leipzig.de>
Subject Null Pointer Exception in tests but only in COLLECTION mode
Date Fri, 20 Nov 2015 17:41:45 GMT
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 COLLECTION mode.

Here is the minimal example on 1.0-SNAPSHOT:
https://gist.github.com/p3et/59a65bab11098dd11054

Are we doing something wrong, or is this a bug?

Cheers,
Andre

-- 
-------------------------------------------
PhD Student
University of Leipzig
Department of Computer Science
Database Research Group

email: petermann@informatik.uni-leipzig.de
web:   dbs.uni-leipzig.de
-------------------------------------------

Mime
View raw message