Hi!

Do you use UNION type (is "exec.enable_union_type" enabled)?
This feature is experimental:
https://drill.apache.org/docs/json-data-model/#experimental-feature-heterogeneous-types

Kind regards
Vitalii


On Thu, Jan 17, 2019 at 9:52 PM 陈。 <lroy_z@qq.com> wrote:

>
>
>
> ------------------ 原始邮件 ------------------
> *发件人:* "陈。"<lroy_z@qq.com>;
> *发送时间:* 2019年1月17日(星期四) 上午10:52
> *收件人:* "user-subscribe"<user-subscribe@drill.apache.org>;
> *主题:* N4}[48H$DHWIOXNQQB%~$GD
>
> I don't know if it's due to an empty result
> query sql
> select `6a993905-f23e-4f1a-967a-0d7504e64740`.`委托任务名称` as
> `委托任务名称`,`6a993905-f23e-4f1a-967a-0d7504e64740`.`委托任务编号` as
> `委托任务编号`,`6a993905-f23e-4f1a-967a-0d7504e64740`.`委托分类` as
> `委托分类`,`6a993905-f23e-4f1a-967a-0d7504e64740`.`预估金额(万元)` as
> `预估金额(万元)`,`6a993905-f23e-4f1a-967a-0d7504e64740`.`预估工作量` as
> `预估工作量`,`6a993905-f23e-4f1a-967a-0d7504e64740`.`甲方` as
> `甲方`,`6a993905-f23e-4f1a-967a-0d7504e64740`.`甲方联系人` as
> `甲方联系人`,`6a993905-f23e-4f1a-967a-0d7504e64740`.`联系电话` as
> `联系电话`,`6a993905-f23e-4f1a-967a-0d7504e64740`.`主责部门` as
> `主责部门`,`6a993905-f23e-4f1a-967a-0d7504e64740`.`委托日期` as
> `委托日期`,`6a993905-f23e-4f1a-967a-0d7504e64740`.`约定完工日期` as
> `约定完工日期`,`6a993905-f23e-4f1a-967a-0d7504e64740`.`状态` as
> `状态`,`6a993905-f23e-4f1a-967a-0d7504e64740`.`附件` as
> `附件`,`6a993905-f23e-4f1a-967a-0d7504e64740`.`备注` as
> `备注`,`6a993905-f23e-4f1a-967a-0d7504e64740`.`登记人` as
> `登记人`,`6a993905-f23e-4f1a-967a-0d7504e64740`.`登记时间` as
> `登记时间`,`30cf7541-fbed-4a42-acea-86e46822b31a`.`合同编号` as
> `合同编号`,`30cf7541-fbed-4a42-acea-86e46822b31a`.`合同名称` as
> `合同名称`,`30cf7541-fbed-4a42-acea-86e46822b31a`.`项目类型(小类)` as
> `项目类型(小类)`,`30cf7541-fbed-4a42-acea-86e46822b31a`.`项目类型(大类)` as
> `项目类型(大类)`,`30cf7541-fbed-4a42-acea-86e46822b31a`.`合同额(万元)` as
> `合同额(万元)`,`5eb9d0e4-0f63-44cf-b1d2-29228a423db3`.`name` as
> `name`,`fbd15f17-9fb3-4283-a6b5-89c47014a627`.`ID` as
> `ID`,`fbd15f17-9fb3-4283-a6b5-89c47014a627`.`已采` as
> `已采`,`fbd15f17-9fb3-4283-a6b5-89c47014a627`.`已发` as
> `已发`,`fbd15f17-9fb3-4283-a6b5-89c47014a627`.`电商平台` as
> `电商平台`,`fbd15f17-9fb3-4283-a6b5-89c47014a627`.`平台` as
> `平台`,`fbd15f17-9fb3-4283-a6b5-89c47014a627`.`标题` as
> `标题`,`fbd15f17-9fb3-4283-a6b5-89c47014a627`.`评论` as
> `评论`,`fbd15f17-9fb3-4283-a6b5-89c47014a627`.`时间` as
> `时间`,`fbd15f17-9fb3-4283-a6b5-89c47014a627`.`PAGEURL` as
> `PAGEURL`,`b63343f4-a65c-47f2-8e70-ae48c85d181d`.`省名称` as
> `省名称`,`b63343f4-a65c-47f2-8e70-ae48c85d181d`.`省简称` as
> `省简称`,`b63343f4-a65c-47f2-8e70-ae48c85d181d`.`所属国家` as
> `所属国家`,`b63343f4-a65c-47f2-8e70-ae48c85d181d`.`省编号` as
> `省编号`,`b63343f4-a65c-47f2-8e70-ae48c85d181d`.`描述` as
> `描述`,`b63343f4-a65c-47f2-8e70-ae48c85d181d`.`外键` as `外键` from (select
> `附件`,`甲方联系人`,`约定完工日期`,`状态`,`登记时间`,`登记人`,`委托分类`,`甲方`,`备注`,`委托日期`,`预估工作量`,`联系电话`,`预估金额(万元)`,`主责部门`,`委托任务编号`,`委托任务名称`
> from mongo.`lzdataplatformbusiness`.`dP_OperationControlCooperation` where
> leadingDPWorkTableId='351501113310052353')
> `6a993905-f23e-4f1a-967a-0d7504e64740` left join(select
> `项目类型(大类)`,`合同额(万元)`,`项目类型(小类)`,`合同编号`,`合同名称` from
> mongo.`lzdataplatformbusiness`.`dP_Mysql` where
> leadingDPWorkTableId='351501113343606784')
> `30cf7541-fbed-4a42-acea-86e46822b31a`  on cast(
> `6a993905-f23e-4f1a-967a-0d7504e64740`.`委托任务名称` as varchar)=cast(
> `30cf7541-fbed-4a42-acea-86e46822b31a`.`合同编号` as varchar) left join(select
> `name` from mongo.`lzdataplatformbusiness`.`dP_Sqlserver` where
> leadingDPWorkTableId='351501113364578304')
> `5eb9d0e4-0f63-44cf-b1d2-29228a423db3`  on cast(
> `30cf7541-fbed-4a42-acea-86e46822b31a`.`合同编号` as varchar)=cast(
> `5eb9d0e4-0f63-44cf-b1d2-29228a423db3`.`name` as varchar) left join(select
> `时间`,`已发`,`平台`,`PAGEURL`,`评论`,`ID`,`标题`,`电商平台`,`已采` from
> mongo.`lzdataplatformbusiness`.`dP_Oracle` where
> leadingDPWorkTableId='351501113389744128')
> `fbd15f17-9fb3-4283-a6b5-89c47014a627`  on cast(
> `5eb9d0e4-0f63-44cf-b1d2-29228a423db3`.`name` as varchar)=cast(
> `fbd15f17-9fb3-4283-a6b5-89c47014a627`.`ID` as varchar) left join(select
> `外键`,`所属国家`,`省编号`,`省名称`,`描述`,`省简称` from
> mongo.`lzdataplatformbusiness`.`dP_Excel` where
> leadingDPWorkTableId='351501113284886529')
> `b63343f4-a65c-47f2-8e70-ae48c85d181d`  on cast(
> `fbd15f17-9fb3-4283-a6b5-89c47014a627`.`ID` as varchar)=cast(
> `b63343f4-a65c-47f2-8e70-ae48c85d181d`.`省名称` as varchar)
>
> Exception
> java.util.concurrent.ExecutionException: java.lang.IllegalStateException:
> Failure while reading vector.  Expected vector class of
> org.apache.drill.exec.vector.NullableVarCharVector but was holding vector
> class org.apache.drill.exec.vector.complex.UnionVector, field= [`name`
> (UNION:OPTIONAL), subtypes=([VARCHAR, INT]), children=([`internal`
> (MAP:REQUIRED), children=([`types` (UINT1:REQUIRED)])])]
> at
> org.apache.drill.exec.physical.impl.partitionsender.PartitionerDecorator$PartitionerTask.run(PartitionerDecorator.java:347)
> ~[drill-java-exec-1.14.0.jar:1.14.0]
> at
> com.google.common.util.concurrent.MoreExecutors$DirectExecutorService.execute(MoreExecutors.java:299)
> ~[guava-18.0.jar:na]
> at
> org.apache.drill.exec.physical.impl.partitionsender.PartitionerDecorator.createAndExecute(PartitionerDecorator.java:172)
> ~[drill-java-exec-1.14.0.jar:1.14.0]
> at
> org.apache.drill.exec.physical.impl.partitionsender.PartitionerDecorator.lambda$executeMethodLogic$0(PartitionerDecorator.java:152)
> ~[drill-java-exec-1.14.0.jar:1.14.0]
> at java.util.ArrayList.forEach(ArrayList.java:1257) ~[na:1.8.0_181]
> at
> org.apache.drill.exec.physical.impl.partitionsender.PartitionerDecorator.executeMethodLogic(PartitionerDecorator.java:152)
> ~[drill-java-exec-1.14.0.jar:1.14.0]
> at
> org.apache.drill.exec.physical.impl.partitionsender.PartitionerDecorator.flushOutgoingBatches(PartitionerDecorator.java:91)
> ~[drill-java-exec-1.14.0.jar:1.14.0]
> at
> org.apache.drill.exec.physical.impl.partitionsender.PartitionSenderRootExec.innerNext(PartitionSenderRootExec.java:191)
> ~[drill-java-exec-1.14.0.jar:1.14.0]
> at
> org.apache.drill.exec.physical.impl.BaseRootExec.next(BaseRootExec.java:93)
> [drill-java-exec-1.14.0.jar:1.14.0]
> at
> org.apache.drill.exec.work.fragment.FragmentExecutor$1.run(FragmentExecutor.java:294)
> [drill-java-exec-1.14.0.jar:1.14.0]
> at
> org.apache.drill.exec.work.fragment.FragmentExecutor$1.run(FragmentExecutor.java:281)
> [drill-java-exec-1.14.0.jar:1.14.0]
> at java.security.AccessController.doPrivileged(Native Method)
> [na:1.8.0_181]
> at javax.security.auth.Subject.doAs(Subject.java:422) [na:1.8.0_181]
> at
> org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1657)
> [hadoop-common-2.7.1.jar:na]
> at
> org.apache.drill.exec.work.fragment.FragmentExecutor.run(FragmentExecutor.java:281)
> [drill-java-exec-1.14.0.jar:1.14.0]
> at
> org.apache.drill.common.SelfCleaningRunnable.run(SelfCleaningRunnable.java:38)
> [drill-common-1.14.0.jar:1.14.0]
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> [na:1.8.0_181]
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> [na:1.8.0_181]
> at java.lang.Thread.run(Thread.java:748) [na:1.8.0_181]
> Caused by: java.lang.IllegalStateException: Failure while reading vector.
> Expected vector class of org.apache.drill.exec.vector.NullableVarCharVector
> but was holding vector class
> org.apache.drill.exec.vector.complex.UnionVector, field= [`name`
> (UNION:OPTIONAL), subtypes=([VARCHAR, INT]), children=([`internal`
> (MAP:REQUIRED), children=([`types` (UINT1:REQUIRED)])])]
> at
> org.apache.drill.exec.record.VectorContainer.getValueAccessorById(VectorContainer.java:324)
> ~[drill-java-exec-1.14.0.jar:1.14.0]
> at
> org.apache.drill.exec.record.RecordBatchLoader.getValueAccessorById(RecordBatchLoader.java:251)
> ~[drill-java-exec-1.14.0.jar:1.14.0]
> at
> org.apache.drill.exec.physical.impl.unorderedreceiver.UnorderedReceiverBatch.getValueAccessorById(UnorderedReceiverBatch.java:139)
> ~[drill-java-exec-1.14.0.jar:1.14.0]
> at
> org.apache.drill.exec.test.generated.PartitionerGen8454$OutgoingRecordBatch.doSetup(PartitionerTemplate.java:563)
> ~[na:na]
> at
> org.apache.drill.exec.test.generated.PartitionerGen8454$OutgoingRecordBatch.initializeBatch(PartitionerTemplate.java:387)
> ~[na:na]
> at
> org.apache.drill.exec.test.generated.PartitionerGen8454.flushOutgoingBatches(PartitionerTemplate.java:173)
> ~[na:na]
> at
> org.apache.drill.exec.physical.impl.partitionsender.PartitionerDecorator$FlushBatchesHandlingClass.execute(PartitionerDecorator.java:285)
> ~[drill-java-exec-1.14.0.jar:1.14.0]
> at
> org.apache.drill.exec.physical.impl.partitionsender.PartitionerDecorator$PartitionerTask.run(PartitionerDecorator.java:340)
> ~[drill-java-exec-1.14.0.jar:1.14.0]
> ... 18 common frames omitted
>
>