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: peterm...@informatik.uni-leipzig.de
web: dbs.uni-leipzig.de
-------------------------------------------
