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 陈。 wrote: > > > > ------------------ 原始邮件 ------------------ > *发件人:* "陈。"; > *发送时间:* 2019年1月17日(星期四) 上午10:52 > *收件人:* "user-subscribe"; > *主题:* 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 > >