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
