Return-Path: X-Original-To: apmail-drill-issues-archive@minotaur.apache.org Delivered-To: apmail-drill-issues-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 7DB1617364 for ; Thu, 2 Apr 2015 01:47:10 +0000 (UTC) Received: (qmail 61058 invoked by uid 500); 2 Apr 2015 01:46:53 -0000 Delivered-To: apmail-drill-issues-archive@drill.apache.org Received: (qmail 61007 invoked by uid 500); 2 Apr 2015 01:46:53 -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 60952 invoked by uid 99); 2 Apr 2015 01:46:53 -0000 Received: from arcas.apache.org (HELO arcas.apache.org) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 02 Apr 2015 01:46:53 +0000 Date: Thu, 2 Apr 2015 01:46:53 +0000 (UTC) From: "Aman Sinha (JIRA)" To: issues@drill.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Updated] (DRILL-2664) StreamingAggregate encounters AssertionError due to outgoing batch being full MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 [ https://issues.apache.org/jira/browse/DRILL-2664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aman Sinha updated DRILL-2664: ------------------------------ Description: Running the following query on TPCH SF 1 encounters AssertionError: {code} alter session set `planner.enable_hashagg` = false; select l_partkey, l_suppkey from lineitem l where 1=1 and (l.l_partkey, l.l_suppkey) in (select o.o_orderkey, o.o_custkey from orders o group by o.o_orderkey, o.o_custkey) group by l.l_partkey, l.l_suppkey; {code} {code} 15:36:38.196 [2ae38d0a-a60c-3f83-b2e7-aa0a48cf6ddf:frag:1:0] ERROR o.a.d.e.w.f.AbstractStatusReporter - Error ae08b35d-3de4-4e70-b238-25aa77c482f0: Failure while running fragment. java.lang.AssertionError: Outgoing RecordBatch is not flushed. It reached its max capacity in the last update at org.apache.drill.exec.test.generated.StreamingAggregatorGen8.outputToBatch(StreamingAggTemplate.java:298) ~[na:na] at org.apache.drill.exec.test.generated.StreamingAggregatorGen8.doWork(StreamingAggTemplate.java:142) ~[na:na] at org.apache.drill.exec.physical.impl.aggregate.StreamingAggBatch.innerNext(StreamingAggBatch.java:127) ~[drill-java-exec-0.8.0-SNAPSHOT-rebuffed.jar:0.8.0-SNAPSHOT] at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:142) ~[drill-java-exec-0.8.0-SNAPSHOT-rebuffed.jar:0.8.0-SNAPSHOT] at org.apache.drill.exec.physical.impl.validate.IteratorValidatorBatchIterator.next(IteratorValidatorBatchIterator.java:118) ~[drill-java-exec-0.8.0-SNAPSHOT-rebuffed.jar:0.8.0-SNAPSHOT] at org.apache.drill.exec.physical.impl.BaseRootExec.next(BaseRootExec.java:67) ~[drill-java-exec-0.8.0-SNAPSHOT-rebuffed.jar:0.8.0-SNAPSHOT] at org.apache.drill.exec.physical.impl.broadcastsender.BroadcastSenderRootExec.innerNext(BroadcastSenderRootExec.java:118) ~[drill-java-exec-0.8.0-SNAPSHOT-rebuffed.jar:0.8.0-SNAPSHOT] at org.apache.drill.exec.physical.impl.BaseRootExec.next(BaseRootExec.java:57) ~[drill-java-exec-0.8.0-SNAPSHOT-rebuffed.jar:0.8.0-SNAPSHOT] at org.apache.drill.exec.work.fragment.FragmentExecutor.run(FragmentExecutor.java:121) ~[drill-java-exec-0.8.0-SNAPSHOT-rebuffed.jar:0.8.0-SNAPSHOT] at org.apache.drill.exec.work.WorkManager$RunnableWrapper.run(WorkManager.java:303) [drill-java-exec-0.8.0-SNAPSHOT-rebuffed.jar:0.8.0-SNAPSHOT] {code} was: Running the following query on TPCH SF 1 encounters AssertionError: {code} alter session set `planner.enable_hashagg` = false; select l_partkey, l_suppkey from lineitem l where 1=1 and (l.l_partkey, l.l_suppkey) in (select o.o_orderkey, o.o_custkey from orders o group by o.o_orderkey, o.o_custkey) group by l.l_partkey, l.l_suppkey; {code} 15:36:38.196 [2ae38d0a-a60c-3f83-b2e7-aa0a48cf6ddf:frag:1:0] ERROR o.a.d.e.w.f.AbstractStatusReporter - Error ae08b35d-3de4-4e70-b238-25aa77c482f0: Failure while running fragment. java.lang.AssertionError: Outgoing RecordBatch is not flushed. It reached its max capacity in the last update at org.apache.drill.exec.test.generated.StreamingAggregatorGen8.outputToBatch(StreamingAggTemplate.java:298) ~[na:na] at org.apache.drill.exec.test.generated.StreamingAggregatorGen8.doWork(StreamingAggTemplate.java:142) ~[na:na] at org.apache.drill.exec.physical.impl.aggregate.StreamingAggBatch.innerNext(StreamingAggBatch.java:127) ~[drill-java-exec-0.8.0-SNAPSHOT-rebuffed.jar:0.8.0-SNAPSHOT] at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:142) ~[drill-java-exec-0.8.0-SNAPSHOT-rebuffed.jar:0.8.0-SNAPSHOT] at org.apache.drill.exec.physical.impl.validate.IteratorValidatorBatchIterator.next(IteratorValidatorBatchIterator.java:118) ~[drill-java-exec-0.8.0-SNAPSHOT-rebuffed.jar:0.8.0-SNAPSHOT] at org.apache.drill.exec.physical.impl.BaseRootExec.next(BaseRootExec.java:67) ~[drill-java-exec-0.8.0-SNAPSHOT-rebuffed.jar:0.8.0-SNAPSHOT] at org.apache.drill.exec.physical.impl.broadcastsender.BroadcastSenderRootExec.innerNext(BroadcastSenderRootExec.java:118) ~[drill-java-exec-0.8.0-SNAPSHOT-rebuffed.jar:0.8.0-SNAPSHOT] at org.apache.drill.exec.physical.impl.BaseRootExec.next(BaseRootExec.java:57) ~[drill-java-exec-0.8.0-SNAPSHOT-rebuffed.jar:0.8.0-SNAPSHOT] at org.apache.drill.exec.work.fragment.FragmentExecutor.run(FragmentExecutor.java:121) ~[drill-java-exec-0.8.0-SNAPSHOT-rebuffed.jar:0.8.0-SNAPSHOT] at org.apache.drill.exec.work.WorkManager$RunnableWrapper.run(WorkManager.java:303) [drill-java-exec-0.8.0-SNAPSHOT-rebuffed.jar:0.8.0-SNAPSHOT] {code} > StreamingAggregate encounters AssertionError due to outgoing batch being full > ----------------------------------------------------------------------------- > > Key: DRILL-2664 > URL: https://issues.apache.org/jira/browse/DRILL-2664 > Project: Apache Drill > Issue Type: Bug > Components: Execution - Relational Operators > Affects Versions: 0.9.0 > Reporter: Aman Sinha > Assignee: Aman Sinha > Priority: Critical > > Running the following query on TPCH SF 1 encounters AssertionError: > {code} > alter session set `planner.enable_hashagg` = false; > select l_partkey, l_suppkey from lineitem l > where 1=1 > and (l.l_partkey, l.l_suppkey) in (select o.o_orderkey, o.o_custkey > from orders o > group by o.o_orderkey, o.o_custkey) > group by l.l_partkey, l.l_suppkey; > {code} > {code} > 15:36:38.196 [2ae38d0a-a60c-3f83-b2e7-aa0a48cf6ddf:frag:1:0] ERROR o.a.d.e.w.f.AbstractStatusReporter - Error ae08b35d-3de4-4e70-b238-25aa77c482f0: Failure while running fragment. > java.lang.AssertionError: Outgoing RecordBatch is not flushed. It reached its max capacity in the last update > at org.apache.drill.exec.test.generated.StreamingAggregatorGen8.outputToBatch(StreamingAggTemplate.java:298) ~[na:na] > at org.apache.drill.exec.test.generated.StreamingAggregatorGen8.doWork(StreamingAggTemplate.java:142) ~[na:na] > at org.apache.drill.exec.physical.impl.aggregate.StreamingAggBatch.innerNext(StreamingAggBatch.java:127) ~[drill-java-exec-0.8.0-SNAPSHOT-rebuffed.jar:0.8.0-SNAPSHOT] > at org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:142) ~[drill-java-exec-0.8.0-SNAPSHOT-rebuffed.jar:0.8.0-SNAPSHOT] > at org.apache.drill.exec.physical.impl.validate.IteratorValidatorBatchIterator.next(IteratorValidatorBatchIterator.java:118) ~[drill-java-exec-0.8.0-SNAPSHOT-rebuffed.jar:0.8.0-SNAPSHOT] > at org.apache.drill.exec.physical.impl.BaseRootExec.next(BaseRootExec.java:67) ~[drill-java-exec-0.8.0-SNAPSHOT-rebuffed.jar:0.8.0-SNAPSHOT] > at org.apache.drill.exec.physical.impl.broadcastsender.BroadcastSenderRootExec.innerNext(BroadcastSenderRootExec.java:118) ~[drill-java-exec-0.8.0-SNAPSHOT-rebuffed.jar:0.8.0-SNAPSHOT] > at org.apache.drill.exec.physical.impl.BaseRootExec.next(BaseRootExec.java:57) ~[drill-java-exec-0.8.0-SNAPSHOT-rebuffed.jar:0.8.0-SNAPSHOT] > at org.apache.drill.exec.work.fragment.FragmentExecutor.run(FragmentExecutor.java:121) ~[drill-java-exec-0.8.0-SNAPSHOT-rebuffed.jar:0.8.0-SNAPSHOT] > at org.apache.drill.exec.work.WorkManager$RunnableWrapper.run(WorkManager.java:303) [drill-java-exec-0.8.0-SNAPSHOT-rebuffed.jar:0.8.0-SNAPSHOT] > {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)