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 526C3200B95 for ; Tue, 13 Sep 2016 03:57:22 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 5101E160AC8; Tue, 13 Sep 2016 01:57:22 +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 99408160AB8 for ; Tue, 13 Sep 2016 03:57:21 +0200 (CEST) Received: (qmail 57402 invoked by uid 500); 13 Sep 2016 01:57:20 -0000 Mailing-List: contact issues-help@drill.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@drill.apache.org Delivered-To: mailing list issues@drill.apache.org Received: (qmail 57388 invoked by uid 99); 13 Sep 2016 01:57:20 -0000 Received: from arcas.apache.org (HELO arcas) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 13 Sep 2016 01:57:20 +0000 Received: from arcas.apache.org (localhost [127.0.0.1]) by arcas (Postfix) with ESMTP id 6E7BC2C014C for ; Tue, 13 Sep 2016 01:57:20 +0000 (UTC) Date: Tue, 13 Sep 2016 01:57:20 +0000 (UTC) From: "Aman Sinha (JIRA)" To: issues@drill.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Commented] (DRILL-2234) IOOB when streaming aggregate is on the left side of hash join MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 archived-at: Tue, 13 Sep 2016 01:57:22 -0000 [ https://issues.apache.org/jira/browse/DRILL-2234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15485961#comment-15485961 ] Aman Sinha commented on DRILL-2234: ----------------------------------- The following query will also reproduce the IOOB without needing to enable SwapJoinRule. {noformat} alter session set `planner.slice_target` = 1; alter session set `planner.enable_hashagg` = false; alter session set `planner.enable_streamagg` = true; alter session set `exec.errors.verbose` = true; 0: jdbc:drill:zk=local> select * from (select l_orderkey from cp.`tpch/lineitem.parquet` group by l_orderkey) l inner join cp.`tpch/orders.parquet` o on l.l_orderkey = o.o_orderkey where o.o_custkey = 10; Error: SYSTEM ERROR: IndexOutOfBoundsException: Index: 9, Size: 0 Fragment 1:0 [Error Id: 96bfcf35-9651-4118-899b-c7e287b6fdce on 10.250.57.118:31010] (java.lang.IndexOutOfBoundsException) Index: 9, Size: 0 java.util.ArrayList.rangeCheck():635 java.util.ArrayList.get():411 org.apache.drill.exec.record.VectorContainer.getValueAccessorById():283 org.apache.drill.exec.record.RecordBatchLoader.getValueAccessorById():178 org.apache.drill.exec.physical.impl.unorderedreceiver.UnorderedReceiverBatch.getValueAccessorById():135 org.apache.drill.exec.physical.impl.validate.IteratorValidatorBatchIterator.getValueAccessorById():188 org.apache.drill.exec.test.generated.HashTableGen13.doSetup():21 org.apache.drill.exec.test.generated.HashTableGen13.updateBatches():484 org.apache.drill.exec.test.generated.HashJoinProbeGen19.executeProbePhase():139 org.apache.drill.exec.test.generated.HashJoinProbeGen19.probeAndProject():223 .... {noformat} > IOOB when streaming aggregate is on the left side of hash join > -------------------------------------------------------------- > > Key: DRILL-2234 > URL: https://issues.apache.org/jira/browse/DRILL-2234 > Project: Apache Drill > Issue Type: Bug > Components: Execution - Relational Operators > Reporter: Mehant Baid > Assignee: Boaz Ben-Zvi > Fix For: Future > > > This issue is similar to DRILL-2107. > Issue can be reproduced by enabling SwapJoinRule in DrillRuleSets and running the following query. > alter session set `planner.slice_target` = 1; > alter session set `planner.enable_hashagg` = false; > alter session set `planner.enable_streamagg` = true; > select l_suppkey, sum(l_extendedprice)/sum(l_quantity) as avg_price > from cp.`tpch/lineitem.parquet` where l_orderkey in > (select o_orderkey from cp.`tpch/orders.parquet` where o_custkey = 2) > group by l_suppkey having sum(l_extendedprice)/sum(l_quantity) > 1850.0; -- This message was sent by Atlassian JIRA (v6.3.4#6332)