Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id EAB91200C0F for ; Thu, 2 Feb 2017 09:57:50 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id E7CB5160B57; Thu, 2 Feb 2017 08:57:50 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 9FFB5160B54 for ; Thu, 2 Feb 2017 09:57:49 +0100 (CET) Received: (qmail 30490 invoked by uid 500); 2 Feb 2017 08:57:48 -0000 Mailing-List: contact dev-help@calcite.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@calcite.apache.org Delivered-To: mailing list dev@calcite.apache.org Received: (qmail 30478 invoked by uid 99); 2 Feb 2017 08:57:47 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd1-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 02 Feb 2017 08:57:47 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd1-us-west.apache.org (ASF Mail Server at spamd1-us-west.apache.org) with ESMTP id 1E1E1C11E8 for ; Thu, 2 Feb 2017 08:57:47 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -0.022 X-Spam-Level: X-Spam-Status: No, score=-0.022 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, SPF_HELO_PASS=-0.001, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd1-us-west.apache.org (amavisd-new); dkim=pass (1024-bit key) header.d=epam.onmicrosoft.com Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id eK7BJG4_wnWu for ; Thu, 2 Feb 2017 08:57:46 +0000 (UTC) Received: from EUR02-VE1-obe.outbound.protection.outlook.com (mail-eopbgr20066.outbound.protection.outlook.com [40.107.2.66]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTPS id C3B755F30B for ; Thu, 2 Feb 2017 08:57:45 +0000 (UTC) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=EPAM.onmicrosoft.com; s=selector1-epam-com; h=From:Date:Subject:Message-ID:Content-Type:MIME-Version; bh=wnxl220TRnro4LLOzXBJTY1krjo0U8kRZnxHClKPnR0=; b=VMIbOevI1qEHmpigtsXlOMhqctozsf2PZNb1mM44TdZwmZwUcwBE3fQZz+T/NszlA7bnQWaryqQh9KpkvMBwrJClTtu99E4Idf1tVa88R895AyBqrk8leWnPu8Ma+8VrTYGDDDwZZ3C+i2BabN7Qbh2SBfE8+ib3ixerzw9/+4c= Received: from AM4PR03MB1410.eurprd03.prod.outlook.com (10.164.77.152) by AM4PR03MB1410.eurprd03.prod.outlook.com (10.164.77.152) with Microsoft SMTP Server (version=TLS1_2, cipher=TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA384_P384) id 15.1.874.12; Thu, 2 Feb 2017 08:57:21 +0000 Received: from AM4PR03MB1410.eurprd03.prod.outlook.com ([10.164.77.152]) by AM4PR03MB1410.eurprd03.prod.outlook.com ([10.164.77.152]) with mapi id 15.01.0874.021; Thu, 2 Feb 2017 08:57:21 +0000 From: Anton Mushin To: "dev@calcite.apache.org" CC: Timo Walther Subject: Null literals in AggregateReduceFunctionsRule Thread-Topic: Null literals in AggregateReduceFunctionsRule Thread-Index: AdJ9L6/zJHcHYPANRuq6RS4SSVlgfw== Date: Thu, 2 Feb 2017 08:57:21 +0000 Message-ID: Accept-Language: en-US, ru-RU Content-Language: en-US X-MS-Has-Attach: X-MS-TNEF-Correlator: authentication-results: spf=none (sender IP is ) smtp.mailfrom=Anton_Mushin@epam.com; x-originating-ip: [188.128.94.254] x-ms-office365-filtering-correlation-id: 3cd7ebcb-1d64-41dc-c4ac-08d44b497fae x-microsoft-antispam: UriScan:;BCL:0;PCL:0;RULEID:(22001);SRVR:AM4PR03MB1410; x-microsoft-exchange-diagnostics: 1;AM4PR03MB1410;7:fkHt9ODS64/S8gT+694u6F4XuFP+ZppT54ol31wragZcVyord4dJ8KjrUAEOHS1fxxQMWXew6b0thtDUSDjbx98iKGB5SdlQGy05QEPR5CLeslpmOCaSioalyYYtWOf8KUWdjc2Beg8m5Cz9gMMDoWXlvWNJ1hXR4jFukHFvyHeps2j0Knsr4ROfyUS8HERc/R2UV8X/OoW3ubLCQLMep1eeO67+SAEOpfsDRxjdxOufycRGaBj3W919rR0LC0wvaxklVppSIe9mPzW8Vjo3N7dizvX9Tl1973Zv2EglXy4oxy3zcz0VmJa/oaEhb1WSIgPaZplvw7jGPoSlsrK6u8llj6A6WwaBqP1GvTs8yLn5ZJyMmFldKo1QgnzMK+VD3TVPCxsLNmqjs2mE2rG+71Vl/SbOkivtyzqyViygCFFt4YYw6cff6qYraiAhKAtX9tZn01ZSiNV4DcOdlEyOOr3Ff15H8Ft8+kphbtyg/5sDfwp2X9jxy6Cjp27qhLofn4A5Tss15NngqRxv6wMTV84GY3kWFeYWqx3lwVghFklrfhRyr5kblkIbylqFIXDh x-microsoft-antispam-prvs: x-exchange-antispam-report-test: UriScan:(134217032509453)(17755550239193); x-exchange-antispam-report-cfa-test: BCL:0;PCL:0;RULEID:(6040375)(601004)(2401047)(5005006)(8121501046)(3002001)(10201501046)(6041248)(20161123558025)(20161123562025)(20161123564025)(20161123555025)(20161123560025)(6072148);SRVR:AM4PR03MB1410;BCL:0;PCL:0;RULEID:;SRVR:AM4PR03MB1410; x-forefront-prvs: 02065A9E77 x-forefront-antispam-report: SFV:NSPM;SFS:(10009020)(6009001)(7916002)(39450400003)(51414003)(199003)(189002)(101416001)(305945005)(7736002)(53936002)(2351001)(54356999)(106356001)(92566002)(105586002)(3280700002)(4326007)(2906002)(50986999)(66066001)(3480700004)(7696004)(8676002)(5660300001)(8936002)(81156014)(74316002)(110136003)(122556002)(6916009)(81166006)(2900100001)(33656002)(80792005)(3660700001)(1730700003)(6436002)(6306002)(9686003)(97736004)(102836003)(189998001)(99286003)(5640700003)(6506006)(55016002)(86362001)(3846002)(6116002)(25786008)(38730400001)(2501003)(77096006)(68736007);DIR:OUT;SFP:1101;SCL:1;SRVR:AM4PR03MB1410;H:AM4PR03MB1410.eurprd03.prod.outlook.com;FPR:;SPF:None;PTR:InfoNoRecords;A:1;MX:1;LANG:en; received-spf: None (protection.outlook.com: epam.com does not designate permitted sender hosts) spamdiagnosticoutput: 1:99 spamdiagnosticmetadata: NSPM Content-Type: text/plain; charset="us-ascii" Content-Transfer-Encoding: quoted-printable MIME-Version: 1.0 X-OriginatorOrg: epam.com X-MS-Exchange-CrossTenant-originalarrivaltime: 02 Feb 2017 08:57:21.1517 (UTC) X-MS-Exchange-CrossTenant-fromentityheader: Hosted X-MS-Exchange-CrossTenant-id: b41b72d0-4e9f-4c26-8a69-f949f367c91d X-MS-Exchange-Transport-CrossTenantHeadersStamped: AM4PR03MB1410 archived-at: Thu, 02 Feb 2017 08:57:51 -0000 Hello community, I have worked for support standard deviation/variance functions in Flink S= QL [1] and I got exception " Type NULL is not supported. Null values must h= ave a supported type.".=20 I started search root cause and found what problem come up from AggregateRe= duceFunctionsRule[2]. @twalthr confirmed it after[3]. Now I have been used WA - the copy AggregateReduceFunctionsRule inside Flin= k with changes. Could we resolve the problem some way? I look forward to your reply. [1] https://issues.apache.org/jira/browse/FLINK-4604# [2] https://issues.apache.org/jira/browse/FLINK-4604?focusedCommentId=3D156= 15280&page=3Dcom.atlassian.jira.plugin.system.issuetabpanels:comment-tabpan= el#comment-15615280 [3] https://issues.apache.org/jira/browse/FLINK-4604?focusedCommentId=3D156= 67697&page=3Dcom.atlassian.jira.plugin.system.issuetabpanels:comment-tabpan= el#comment-15667697 Regards, Anton Mushin