[
https://issues.apache.org/jira/browse/DRILL-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacques Nadeau resolved DRILL-1967.
-----------------------------------
Resolution: Fixed
Fixed in 838fd08
> Null pointer exception in ParquetRecordWriter when caneled before data arrives
> ------------------------------------------------------------------------------
>
> Key: DRILL-1967
> URL: https://issues.apache.org/jira/browse/DRILL-1967
> Project: Apache Drill
> Issue Type: Bug
> Components: Storage - Parquet
> Reporter: Jason Altekruse
> Assignee: Jason Altekruse
> Fix For: 0.8.0
>
> Attachments: DRILL-1967.patch
>
>
> To reproduce:
> create table my_table select a from json_table.json;
> json_table.json:
> {
> "a" : "a string"
> }
> {
> "a" : 1
> }
> The schema change will cause an error before a batch is ever sent to the
> writer. This causes a null pointer in the cleanup method.
> java.lang.NullPointerException
>
> org.apache.drill.exec.store.parquet.ParquetRecordWriter.cleanup(ParquetRecordWriter.java:298)
> ~[classes/:na]
>
> org.apache.drill.exec.physical.impl.WriterRecordBatch.cleanup(WriterRecordBatch.java:187)
> ~[classes/:na]
>
> org.apache.drill.exec.physical.impl.validate.IteratorValidatorBatchIterator.cleanup(IteratorValidatorBatchIterator.java:148)
> ~[classes/:na]
>
> org.apache.drill.exec.record.AbstractSingleRecordBatch.cleanup(AbstractSingleRecordBatch.java:121)
> ~[classes/:na]
>
> org.apache.drill.exec.physical.impl.validate.IteratorValidatorBatchIterator.cleanup(IteratorValidatorBatchIterator.java:148)
> ~[classes/:na]
>
> org.apache.drill.exec.physical.impl.ScreenCreator$ScreenRoot.internalStop(ScreenCreator.java:178)
> ~[classes/:na]
>
> org.apache.drill.exec.physical.impl.ScreenCreator$ScreenRoot.innerNext(ScreenCreator.java:101)
> ~[classes/:na]
>
> org.apache.drill.exec.physical.impl.BaseRootExec.next(BaseRootExec.java:57)
> ~[classes/:na]
>
> org.apache.drill.exec.work.fragment.FragmentExecutor.run(FragmentExecutor.java:114)
> ~[classes/:na]
>
> org.apache.drill.exec.work.WorkManager$RunnableWrapper.run(WorkManager.java:254)
> [classes/:na]
>
> 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]
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
