incubator-drill-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Andy Pernsteiner <apernstei...@maprtech.com>
Subject Joining two views yields: You tried to do a batch data read operation when you were in a state of STOP
Date Fri, 01 Aug 2014 22:40:42 GMT
The query below yields an interesting error I'd not seen before.  Basically
I'm re-creating a query which Tableau tried to execute against a pair of
drill-created views.

Not clear on what 'OK' or 'OK_NEW_SCHEMA' refer to in this context..is
there a way for me to solve this?




0: jdbc:drill:>  SELECT `logview`.`camp_id` AS `none_camp_id_ok`,
. . . . . . . >   `prodview`.`category` AS `none_category_nk`
. . . . . . . > FROM `click`.`views`.`logview` `logview`
. . . . . . . >   INNER JOIN `click`.`views`.`prodview` `prodview` ON
(`logview`.`prod_id` = `prodview`.`prod_id`)
. . . . . . . > GROUP BY `logview`.`camp_id`,
. . . . . . . >   `prodview`.`category` ;
*Query failed: Failure while running fragment. You tried to do a batch data
read operation when you were in a state of STOP.  You can only do this type
of operation when you are in a state of OK or OK_NEW_SCHEMA.
[6b5ceaab-2594-40fe-81be-b52a07ced155]*
Node details: ip-172-16-1-111:31011/31012
java.lang.IllegalStateException: You tried to do a batch data read
operation when you were in a state of STOP.  You can only do this type of
operation when you are in a state of OK or OK_NEW_SCHEMA.
at
org.apache.drill.exec.physical.impl.validate.IteratorValidatorBatchIterator.validateReadState(IteratorValidatorBatchIterator.java:54)
at
org.apache.drill.exec.physical.impl.validate.IteratorValidatorBatchIterator.iterator(IteratorValidatorBatchIterator.java:64)
at
org.apache.drill.exec.test.generated.HashJoinProbeGen221.executeProbePhase(HashJoinProbeTemplate.java:116)
at
org.apache.drill.exec.test.generated.HashJoinProbeGen221.probeAndProject(HashJoinProbeTemplate.java:246)
at
org.apache.drill.exec.physical.impl.join.HashJoinBatch.innerNext(HashJoinBatch.java:212)
at
org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:95)
at
org.apache.drill.exec.physical.impl.validate.IteratorValidatorBatchIterator.next(IteratorValidatorBatchIterator.java:116)
at
org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:75)
at
org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:65)
at
org.apache.drill.exec.record.AbstractSingleRecordBatch.innerNext(AbstractSingleRecordBatch.java:45)
at
org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:120)
at
org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:95)
at
org.apache.drill.exec.physical.impl.validate.IteratorValidatorBatchIterator.next(IteratorValidatorBatchIterator.java:116)
at
org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:75)
at
org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:65)
at
org.apache.drill.exec.physical.impl.aggregate.HashAggBatch.innerNext(HashAggBatch.java:101)
at
org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:95)
at
org.apache.drill.exec.physical.impl.validate.IteratorValidatorBatchIterator.next(IteratorValidatorBatchIterator.java:116)
at
org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:75)
at
org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:65)
at
org.apache.drill.exec.record.AbstractSingleRecordBatch.innerNext(AbstractSingleRecordBatch.java:45)
at
org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext(ProjectRecordBatch.java:120)
at
org.apache.drill.exec.record.AbstractRecordBatch.next(AbstractRecordBatch.java:95)
at
org.apache.drill.exec.physical.impl.validate.IteratorValidatorBatchIterator.next(IteratorValidatorBatchIterator.java:116)
at
org.apache.drill.exec.physical.impl.BaseRootExec.next(BaseRootExec.java:59)
at
org.apache.drill.exec.physical.impl.ScreenCreator$ScreenRoot.innerNext(ScreenCreator.java:98)
at
org.apache.drill.exec.physical.impl.BaseRootExec.next(BaseRootExec.java:49)
at
org.apache.drill.exec.work.fragment.FragmentExecutor.run(FragmentExecutor.java:116)
at
org.apache.drill.exec.work.WorkManager$RunnableWrapper.run(WorkManager.java:250)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)


Error: exception while executing query: Failure while trying to get next
result batch. (state=,code=0)


-- 
 Andy Pernsteiner
 Manager, Field Enablement
ph: 206.228.0737

www.mapr.com

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message