[DRILL-200] deadbuff when doing count(1) on table with multiple batches

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.1.0-m1
• Assignee: Unassigned
• Reporter: Steven Phillips
• Created: 03/Sep/13 22:17
• Updated: 09/Oct/13 18:09
• Resolved: 04/Sep/13 11:40

Description

Here is the query:
select count(1) from "/tmp/tpc-h/supplier";

It gives this error:
java.lang.UnsupportedOperationException: Attemped to access a DeadBuf. This would happen if you attempted to interact with a buffer that has been moved or not yet initialized.
org.apache.drill.exec.record.DeadBuf.getLong(DeadBuf.java:250) ~[java-exec-1.0-SNAPSHOT-rebuffed.jar:1.0-SNAPSHOT]
org.apache.drill.exec.vector.BigIntVector$Accessor.get(BigIntVector.java:187) ~[java-exec-1.0-SNAPSHOT-rebuffed.jar:1.0-SNAPSHOT]
org.apache.drill.exec.test.generated.Gen3.addRecord(AggTemplate.java:24) ~[na:na]
org.apache.drill.exec.test.generated.Gen3.addRecordInc(AggTemplate.java:268) ~[na:na]
org.apache.drill.exec.test.generated.Gen3.doWork(AggTemplate.java:176) ~[na:na]
org.apache.drill.exec.physical.impl.aggregate.AggBatch.next(AggBatch.java:89) ~[java-exec-1.0-SNAPSHOT-rebuffed.jar:1.0-SNAPSHOT]
org.apache.drill.exec.record.AbstractSingleRecordBatch.next(AbstractSingleRecordBatch.java:25) ~[java-exec-1.0-SNAPSHOT-rebuffed.jar:1.0-SNAPSHOT]
org.apache.drill.exec.physical.impl.ScreenCreator$ScreenRoot.next(ScreenCreator.java:77) ~[java-exec-1.0-SNAPSHOT-rebuffed.jar:1.0-SNAPSHOT]
org.apache.drill.exec.work.FragmentRunner.run(FragmentRunner.java:79) ~[java-exec-1.0-SNAPSHOT-rebuffed.jar:1.0-SNAPSHOT]
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) [na:1.7.0_21]
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) [na:1.7.0_21]
java.lang.Thread.run(Thread.java:722) [na:1.7.0_21]

Here is the physical plan that is generated:

{
head : {
type : "APACHE_DRILL_PHYSICAL",
version : 1,
generator :

{ type : "optiq", info : "na" }

},
graph : [ {
pop : "parquet-scan",
@id : 1,
entries : [

{ path : "/tmp/tpc-h/supplier" }

],
storageengine :

{ type : "parquet", dfsName : "file:///" }

,
ref : "_MAP",
fragmentPointer : 0
}, {
pop : "project",
@id : 2,
exprs : [

{ ref : "output.$f0", expr : "1" }

],
child : 1
},

{ pop : "sort", @id : 3, child : 2, orderings : [ ], reverse : false }

, {
pop : "streaming-aggregate",
@id : 4,
child : 3,
keys : [ ],
exprs : [

{ ref : "EXPR$0", expr : "count($f0) " }

]
},

{ pop : "selection-vector-remover", @id : 5, child : 4 }

,

{ pop : "screen", @id : 6, child : 5 }

]
}