[ https://issues.apache.org/jira/browse/DRILL-2664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14392152#comment-14392152 ]
Venki Korukanti commented on DRILL-2664: ---------------------------------------- LGTM, +1. Please add the repro test to functional test suite. > 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 > Attachments: > 0001-DRILL-2664-In-StreamingAgg-fix-issues-with-handling-.patch > > > 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)