Return-Path: X-Original-To: apmail-flink-dev-archive@www.apache.org Delivered-To: apmail-flink-dev-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 5FACF18BF1 for ; Fri, 20 Nov 2015 17:42:06 +0000 (UTC) Received: (qmail 97453 invoked by uid 500); 20 Nov 2015 17:42:06 -0000 Delivered-To: apmail-flink-dev-archive@flink.apache.org Received: (qmail 97401 invoked by uid 500); 20 Nov 2015 17:42:06 -0000 Mailing-List: contact dev-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flink.apache.org Delivered-To: mailing list dev@flink.apache.org Received: (qmail 97390 invoked by uid 99); 20 Nov 2015 17:42:05 -0000 Received: from Unknown (HELO spamd4-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 20 Nov 2015 17:42:05 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd4-us-west.apache.org (ASF Mail Server at spamd4-us-west.apache.org) with ESMTP id 9129DC0F4B for ; Fri, 20 Nov 2015 17:42:05 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1.791 X-Spam-Level: * X-Spam-Status: No, score=1.791 tagged_above=-999 required=6.31 tests=[KAM_ASCII_DIVIDERS=0.8, KAM_LAZY_DOMAIN_SECURITY=1, T_RP_MATCHES_RCVD=-0.01, URIBL_BLOCKED=0.001] autolearn=disabled Received: from mx1-us-west.apache.org ([10.40.0.8]) by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id Z6hnXm_OXMYP for ; Fri, 20 Nov 2015 17:41:53 +0000 (UTC) Received: from v1.rz.uni-leipzig.de (v1.rz.uni-leipzig.de [139.18.1.26]) by mx1-us-west.apache.org (ASF Mail Server at mx1-us-west.apache.org) with ESMTPS id 94BD220FFE for ; Fri, 20 Nov 2015 17:41:53 +0000 (UTC) Received: from localhost (localhost [127.0.0.1]) by v1.rz.uni-leipzig.de (Postfix) with ESMTP id DF71BB4050 for ; Fri, 20 Nov 2015 18:41:45 +0100 (CET) X-Virus-Scanned: by amavisd-new at v1-ul Received: from v1.rz.uni-leipzig.de ([127.0.0.1]) by localhost (v1.rz.uni-leipzig.de [127.0.0.1]) (amavisd-new, port 10024) with ESMTP id ssK5K6eTq5Aw for ; Fri, 20 Nov 2015 18:41:45 +0100 (CET) Received: from isun.informatik.uni-leipzig.de (isun.informatik.uni-leipzig.de [139.18.13.50]) by v1.rz.uni-leipzig.de (Postfix) with ESMTPS id CACA5B404F for ; Fri, 20 Nov 2015 18:41:45 +0100 (CET) Received: from smtp.informatik.uni-leipzig.de (smtp.informatik.uni-leipzig.de [139.18.13.51]) by isun.informatik.uni-leipzig.de (8.14.4+Sun/8.14.4) with ESMTP id tAKHfj2W014204 for ; Fri, 20 Nov 2015 18:41:45 +0100 (CET) Received: from [139.18.13.157] (db10.informatik.uni-leipzig.de [139.18.13.157]) (authenticated bits=0) by smtp.informatik.uni-leipzig.de (8.14.3/8.14.3) with ESMTP id tAKHfkuX026192 for ; Fri, 20 Nov 2015 18:41:46 +0100 (CET) To: dev@flink.apache.org From: =?UTF-8?Q?Andr=c3=a9_Petermann?= Subject: Null Pointer Exception in tests but only in COLLECTION mode Message-ID: <564F5B59.8000907@informatik.uni-leipzig.de> Date: Fri, 20 Nov 2015 18:41:45 +0100 User-Agent: Mozilla/5.0 (X11; Linux x86_64; rv:38.0) Gecko/20100101 Thunderbird/38.3.0 MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8; format=flowed Content-Transfer-Encoding: 7bit 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 -------------------------------------------