Re: Storage Plugin for accessing Hive ORC Table from Drill
@Andries, We are using Hive 2.1.1 with Drill 1.9.0. @Zelaine, Could this be a problem in your Hive metastore?--> As i mentioned earlier, i am able to read hive parquet tables in Drill through hive storage plugin. So can you tell me a bit more like which type of configuration i am missing in metastore? Regards, *Anup Tiwari* On Sat, Jan 21, 2017 at 4:56 AM, Zelaine Fongwrote: > The stack trace shows the following: > > Caused by: org.apache.drill.common.exceptions.DrillRuntimeException: > java.io.IOException: Failed to get numRows from HiveTable > > The Drill optimizer is trying to read rowcount information from Hive. > Could this be a problem in your Hive metastore? > > Has anyone else seen this before? > > -- Zelaine > > On 1/20/17, 7:35 AM, "Andries Engelbrecht" wrote: > > What version of Hive are you using? > > > --Andries > > > From: Anup Tiwari > Sent: Friday, January 20, 2017 3:00:43 AM > To: user@drill.apache.org; d...@drill.apache.org > Subject: Re: Storage Plugin for accessing Hive ORC Table from Drill > > Hi, > > Please find below Create Table Statement and subsequent Drill Error :- > > *Table Structure :* > > CREATE TABLE `logindetails_all`( > `sid` char(40), > `channel_id` tinyint, > `c_t` bigint, > `l_t` bigint) > PARTITIONED BY ( > `login_date` char(10)) > CLUSTERED BY ( > channel_id) > INTO 9 BUCKETS > ROW FORMAT SERDE > 'org.apache.hadoop.hive.ql.io.orc.OrcSerde' > STORED AS INPUTFORMAT > 'org.apache.hadoop.hive.ql.io.orc.OrcInputFormat' > OUTPUTFORMAT > 'org.apache.hadoop.hive.ql.io.orc.OrcOutputFormat' > LOCATION > 'hdfs://hostname1:9000/usr/hive/warehouse/logindetails_all' > TBLPROPERTIES ( > 'compactorthreshold.hive.compactor.delta.num.threshold'='6', > 'compactorthreshold.hive.compactor.delta.pct.threshold'='0.5', > 'transactional'='true', > 'transient_lastDdlTime'='1484313383'); > ; > > *Drill Error :* > > *Query* : select * from hive.logindetails_all limit 1; > > *Error :* > 2017-01-20 16:21:12,625 [277e145e-c6bc-3372-01d0-6c5b75b92d73:foreman] > INFO o.a.drill.exec.work.foreman.Foreman - Query text for query id > 277e145e-c6bc-3372-01d0-6c5b75b92d73: select * from > hive.logindetails_all > limit 1 > 2017-01-20 16:21:12,831 [277e145e-c6bc-3372-01d0-6c5b75b92d73:foreman] > ERROR o.a.drill.exec.work.foreman.Foreman - SYSTEM ERROR: > NumberFormatException: For input string: "004_" > > > [Error Id: 53fa92e1-477e-45d2-b6f7-6eab9ef1da35 on > prod-hadoop-101.bom-prod.aws.games24x7.com:31010] > org.apache.drill.common.exceptions.UserException: SYSTEM ERROR: > NumberFormatException: For input string: "004_" > > > [Error Id: 53fa92e1-477e-45d2-b6f7-6eab9ef1da35 on > prod-hadoop-101.bom-prod.aws.games24x7.com:31010] > at > org.apache.drill.common.exceptions.UserException$ > Builder.build(UserException.java:543) > ~[drill-common-1.9.0.jar:1.9.0] > at > org.apache.drill.exec.work.foreman.Foreman$ForemanResult. > close(Foreman.java:825) > [drill-java-exec-1.9.0.jar:1.9.0] > at > org.apache.drill.exec.work.foreman.Foreman.moveToState( > Foreman.java:935) > [drill-java-exec-1.9.0.jar:1.9.0] > at org.apache.drill.exec.work.foreman.Foreman.run(Foreman. > java:281) > [drill-java-exec-1.9.0.jar:1.9.0] > at > java.util.concurrent.ThreadPoolExecutor.runWorker( > ThreadPoolExecutor.java:1142) > [na:1.8.0_72] > at > java.util.concurrent.ThreadPoolExecutor$Worker.run( > ThreadPoolExecutor.java:617) > [na:1.8.0_72] > at java.lang.Thread.run(Thread.java:745) [na:1.8.0_72] > Caused by: org.apache.drill.exec.work.foreman.ForemanException: > Unexpected > exception during fragment initialization: Internal error: Error while > applying rule DrillPushProjIntoScan, args > [rel#4220197:LogicalProject.NONE.ANY([]).[](input=rel# > 4220196:Subset#0.ENUMERABLE.ANY([]).[],sid=$0,channel_id=$ > 1,c_t=$2,l_t=$3,login_date=$4), > rel#4220181:EnumerableTableScan.ENUMERABLE.ANY([]).[](table=[hive, > logindetails_all])] > ... 4 common frames omitted > Caused by: java.lang.AssertionError: Internal error: Error while > applying > rule DrillPushProjIntoScan, args > [rel#4220197:LogicalProject.NONE.ANY([]).[](input=rel# > 4220196:Subset#0.ENUMERABLE.ANY([]).[],sid=$0,channel_id=$ > 1,c_t=$2,l_t=$3,login_date=$4), > rel#4220181:EnumerableTableScan.ENUMERABLE.ANY([]).[](table=[hive, > logindetails_all])] > at org.apache.calcite.util.Util.newInternal(Util.java:792) > ~[calcite-core-1.4.0-drill-r19.jar:1.4.0-drill-r19] > at > org.apache.calcite.plan.volcano.VolcanoRuleCall. > onMatch(VolcanoRuleCall.java:251) >
Re: Storage Plugin for accessing Hive ORC Table from Drill
The stack trace shows the following: Caused by: org.apache.drill.common.exceptions.DrillRuntimeException: java.io.IOException: Failed to get numRows from HiveTable The Drill optimizer is trying to read rowcount information from Hive. Could this be a problem in your Hive metastore? Has anyone else seen this before? -- Zelaine On 1/20/17, 7:35 AM, "Andries Engelbrecht"wrote: What version of Hive are you using? --Andries From: Anup Tiwari Sent: Friday, January 20, 2017 3:00:43 AM To: user@drill.apache.org; d...@drill.apache.org Subject: Re: Storage Plugin for accessing Hive ORC Table from Drill Hi, Please find below Create Table Statement and subsequent Drill Error :- *Table Structure :* CREATE TABLE `logindetails_all`( `sid` char(40), `channel_id` tinyint, `c_t` bigint, `l_t` bigint) PARTITIONED BY ( `login_date` char(10)) CLUSTERED BY ( channel_id) INTO 9 BUCKETS ROW FORMAT SERDE 'org.apache.hadoop.hive.ql.io.orc.OrcSerde' STORED AS INPUTFORMAT 'org.apache.hadoop.hive.ql.io.orc.OrcInputFormat' OUTPUTFORMAT 'org.apache.hadoop.hive.ql.io.orc.OrcOutputFormat' LOCATION 'hdfs://hostname1:9000/usr/hive/warehouse/logindetails_all' TBLPROPERTIES ( 'compactorthreshold.hive.compactor.delta.num.threshold'='6', 'compactorthreshold.hive.compactor.delta.pct.threshold'='0.5', 'transactional'='true', 'transient_lastDdlTime'='1484313383'); ; *Drill Error :* *Query* : select * from hive.logindetails_all limit 1; *Error :* 2017-01-20 16:21:12,625 [277e145e-c6bc-3372-01d0-6c5b75b92d73:foreman] INFO o.a.drill.exec.work.foreman.Foreman - Query text for query id 277e145e-c6bc-3372-01d0-6c5b75b92d73: select * from hive.logindetails_all limit 1 2017-01-20 16:21:12,831 [277e145e-c6bc-3372-01d0-6c5b75b92d73:foreman] ERROR o.a.drill.exec.work.foreman.Foreman - SYSTEM ERROR: NumberFormatException: For input string: "004_" [Error Id: 53fa92e1-477e-45d2-b6f7-6eab9ef1da35 on prod-hadoop-101.bom-prod.aws.games24x7.com:31010] org.apache.drill.common.exceptions.UserException: SYSTEM ERROR: NumberFormatException: For input string: "004_" [Error Id: 53fa92e1-477e-45d2-b6f7-6eab9ef1da35 on prod-hadoop-101.bom-prod.aws.games24x7.com:31010] at org.apache.drill.common.exceptions.UserException$Builder.build(UserException.java:543) ~[drill-common-1.9.0.jar:1.9.0] at org.apache.drill.exec.work.foreman.Foreman$ForemanResult.close(Foreman.java:825) [drill-java-exec-1.9.0.jar:1.9.0] at org.apache.drill.exec.work.foreman.Foreman.moveToState(Foreman.java:935) [drill-java-exec-1.9.0.jar:1.9.0] at org.apache.drill.exec.work.foreman.Foreman.run(Foreman.java:281) [drill-java-exec-1.9.0.jar:1.9.0] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [na:1.8.0_72] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [na:1.8.0_72] at java.lang.Thread.run(Thread.java:745) [na:1.8.0_72] Caused by: org.apache.drill.exec.work.foreman.ForemanException: Unexpected exception during fragment initialization: Internal error: Error while applying rule DrillPushProjIntoScan, args [rel#4220197:LogicalProject.NONE.ANY([]).[](input=rel#4220196:Subset#0.ENUMERABLE.ANY([]).[],sid=$0,channel_id=$1,c_t=$2,l_t=$3,login_date=$4), rel#4220181:EnumerableTableScan.ENUMERABLE.ANY([]).[](table=[hive, logindetails_all])] ... 4 common frames omitted Caused by: java.lang.AssertionError: Internal error: Error while applying rule DrillPushProjIntoScan, args [rel#4220197:LogicalProject.NONE.ANY([]).[](input=rel#4220196:Subset#0.ENUMERABLE.ANY([]).[],sid=$0,channel_id=$1,c_t=$2,l_t=$3,login_date=$4), rel#4220181:EnumerableTableScan.ENUMERABLE.ANY([]).[](table=[hive, logindetails_all])] at org.apache.calcite.util.Util.newInternal(Util.java:792) ~[calcite-core-1.4.0-drill-r19.jar:1.4.0-drill-r19] at org.apache.calcite.plan.volcano.VolcanoRuleCall.onMatch(VolcanoRuleCall.java:251) ~[calcite-core-1.4.0-drill-r19.jar:1.4.0-drill-r19] at org.apache.calcite.plan.volcano.VolcanoPlanner.findBestExp(VolcanoPlanner.java:808) ~[calcite-core-1.4.0-drill-r19.jar:1.4.0-drill-r19] at org.apache.calcite.tools.Programs$RuleSetProgram.run(Programs.java:303) ~[calcite-core-1.4.0-drill-r19.jar:1.4.0-drill-r19] at org.apache.drill.exec.planner.sql.handlers.DefaultSqlHandler.transform(DefaultSqlHandler.java:404) ~[drill-java-exec-1.9.0.jar:1.9.0] at
Support for Kafka
Is there any support to query kakfa from Drill? If not, what is the roadmap/plan to support this feature? Regards Chetan
Re: How to use CASE in apache drill
Are the two columns CS.ProviderID and b.`Value` of the same datatypes in your SQL statement ? From: Sanjiv KumarSent: Friday, January 20, 2017 1:59:35 PM To: user@drill.apache.org Subject: How to use CASE in apache drill I Have one doubt regarding CASE in Apache Drill. I am trying to use CASE in latest version of drill (1.9) in Window system & in embedded mode. SEE MY QUERY:- SELECT CASE WHEN EXISTS (SELECT distinct CS.ProviderID FROM ... AS `CS` INNER JOIN ... AS `PS` ON PS.ID = CS.ProviderID where CS.PluginName = 'some text from db' AND PS.Code = 'SQLSERVER' AND CS.AccessKey = 'B2S1' limit 1) THEN (SELECT distinct b.`Value` from ... AS a inner join ... as b on a.ID = b.PermissionID inner join ... as c on c.RoleID=b.RoleID and c.ModuleID=1 limit 1) ELSE 0 END FROM ...; I am trying to execute this query but it throughing error. SEE ERROR:- org.apache.drill.common.exceptions.UserRemoteException: VALIDATION ERROR: >From line 2, column 1 to line 7, column 4: Illegal mixing of types in CASE or COALESCE statement SQL Query null *What i am doing wrong in this query.?*
Re: Storage Plugin for accessing Hive ORC Table from Drill
What version of Hive are you using? --Andries From: Anup TiwariSent: Friday, January 20, 2017 3:00:43 AM To: user@drill.apache.org; d...@drill.apache.org Subject: Re: Storage Plugin for accessing Hive ORC Table from Drill Hi, Please find below Create Table Statement and subsequent Drill Error :- *Table Structure :* CREATE TABLE `logindetails_all`( `sid` char(40), `channel_id` tinyint, `c_t` bigint, `l_t` bigint) PARTITIONED BY ( `login_date` char(10)) CLUSTERED BY ( channel_id) INTO 9 BUCKETS ROW FORMAT SERDE 'org.apache.hadoop.hive.ql.io.orc.OrcSerde' STORED AS INPUTFORMAT 'org.apache.hadoop.hive.ql.io.orc.OrcInputFormat' OUTPUTFORMAT 'org.apache.hadoop.hive.ql.io.orc.OrcOutputFormat' LOCATION 'hdfs://hostname1:9000/usr/hive/warehouse/logindetails_all' TBLPROPERTIES ( 'compactorthreshold.hive.compactor.delta.num.threshold'='6', 'compactorthreshold.hive.compactor.delta.pct.threshold'='0.5', 'transactional'='true', 'transient_lastDdlTime'='1484313383'); ; *Drill Error :* *Query* : select * from hive.logindetails_all limit 1; *Error :* 2017-01-20 16:21:12,625 [277e145e-c6bc-3372-01d0-6c5b75b92d73:foreman] INFO o.a.drill.exec.work.foreman.Foreman - Query text for query id 277e145e-c6bc-3372-01d0-6c5b75b92d73: select * from hive.logindetails_all limit 1 2017-01-20 16:21:12,831 [277e145e-c6bc-3372-01d0-6c5b75b92d73:foreman] ERROR o.a.drill.exec.work.foreman.Foreman - SYSTEM ERROR: NumberFormatException: For input string: "004_" [Error Id: 53fa92e1-477e-45d2-b6f7-6eab9ef1da35 on prod-hadoop-101.bom-prod.aws.games24x7.com:31010] org.apache.drill.common.exceptions.UserException: SYSTEM ERROR: NumberFormatException: For input string: "004_" [Error Id: 53fa92e1-477e-45d2-b6f7-6eab9ef1da35 on prod-hadoop-101.bom-prod.aws.games24x7.com:31010] at org.apache.drill.common.exceptions.UserException$Builder.build(UserException.java:543) ~[drill-common-1.9.0.jar:1.9.0] at org.apache.drill.exec.work.foreman.Foreman$ForemanResult.close(Foreman.java:825) [drill-java-exec-1.9.0.jar:1.9.0] at org.apache.drill.exec.work.foreman.Foreman.moveToState(Foreman.java:935) [drill-java-exec-1.9.0.jar:1.9.0] at org.apache.drill.exec.work.foreman.Foreman.run(Foreman.java:281) [drill-java-exec-1.9.0.jar:1.9.0] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [na:1.8.0_72] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [na:1.8.0_72] at java.lang.Thread.run(Thread.java:745) [na:1.8.0_72] Caused by: org.apache.drill.exec.work.foreman.ForemanException: Unexpected exception during fragment initialization: Internal error: Error while applying rule DrillPushProjIntoScan, args [rel#4220197:LogicalProject.NONE.ANY([]).[](input=rel#4220196:Subset#0.ENUMERABLE.ANY([]).[],sid=$0,channel_id=$1,c_t=$2,l_t=$3,login_date=$4), rel#4220181:EnumerableTableScan.ENUMERABLE.ANY([]).[](table=[hive, logindetails_all])] ... 4 common frames omitted Caused by: java.lang.AssertionError: Internal error: Error while applying rule DrillPushProjIntoScan, args [rel#4220197:LogicalProject.NONE.ANY([]).[](input=rel#4220196:Subset#0.ENUMERABLE.ANY([]).[],sid=$0,channel_id=$1,c_t=$2,l_t=$3,login_date=$4), rel#4220181:EnumerableTableScan.ENUMERABLE.ANY([]).[](table=[hive, logindetails_all])] at org.apache.calcite.util.Util.newInternal(Util.java:792) ~[calcite-core-1.4.0-drill-r19.jar:1.4.0-drill-r19] at org.apache.calcite.plan.volcano.VolcanoRuleCall.onMatch(VolcanoRuleCall.java:251) ~[calcite-core-1.4.0-drill-r19.jar:1.4.0-drill-r19] at org.apache.calcite.plan.volcano.VolcanoPlanner.findBestExp(VolcanoPlanner.java:808) ~[calcite-core-1.4.0-drill-r19.jar:1.4.0-drill-r19] at org.apache.calcite.tools.Programs$RuleSetProgram.run(Programs.java:303) ~[calcite-core-1.4.0-drill-r19.jar:1.4.0-drill-r19] at org.apache.drill.exec.planner.sql.handlers.DefaultSqlHandler.transform(DefaultSqlHandler.java:404) ~[drill-java-exec-1.9.0.jar:1.9.0] at org.apache.drill.exec.planner.sql.handlers.DefaultSqlHandler.transform(DefaultSqlHandler.java:343) ~[drill-java-exec-1.9.0.jar:1.9.0] at org.apache.drill.exec.planner.sql.handlers.DefaultSqlHandler.convertToDrel(DefaultSqlHandler.java:240) ~[drill-java-exec-1.9.0.jar:1.9.0] at org.apache.drill.exec.planner.sql.handlers.DefaultSqlHandler.convertToDrel(DefaultSqlHandler.java:290) ~[drill-java-exec-1.9.0.jar:1.9.0] at org.apache.drill.exec.planner.sql.handlers.DefaultSqlHandler.getPlan(DefaultSqlHandler.java:168) ~[drill-java-exec-1.9.0.jar:1.9.0] at org.apache.drill.exec.planner.sql.DrillSqlWorker.getPhysicalPlan(DrillSqlWorker.java:123) ~[drill-java-exec-1.9.0.jar:1.9.0] at org.apache.drill.exec.planner.sql.DrillSqlWorker.getPlan(DrillSqlWorker.java:97) ~[drill-java-exec-1.9.0.jar:1.9.0] at org.apache.drill.exec.work.foreman.Foreman.runSQL(Foreman.java:1008)
Re: Storage Plugin for accessing Hive ORC Table from Drill
Hi, Please find below Create Table Statement and subsequent Drill Error :- *Table Structure :* CREATE TABLE `logindetails_all`( `sid` char(40), `channel_id` tinyint, `c_t` bigint, `l_t` bigint) PARTITIONED BY ( `login_date` char(10)) CLUSTERED BY ( channel_id) INTO 9 BUCKETS ROW FORMAT SERDE 'org.apache.hadoop.hive.ql.io.orc.OrcSerde' STORED AS INPUTFORMAT 'org.apache.hadoop.hive.ql.io.orc.OrcInputFormat' OUTPUTFORMAT 'org.apache.hadoop.hive.ql.io.orc.OrcOutputFormat' LOCATION 'hdfs://hostname1:9000/usr/hive/warehouse/logindetails_all' TBLPROPERTIES ( 'compactorthreshold.hive.compactor.delta.num.threshold'='6', 'compactorthreshold.hive.compactor.delta.pct.threshold'='0.5', 'transactional'='true', 'transient_lastDdlTime'='1484313383'); ; *Drill Error :* *Query* : select * from hive.logindetails_all limit 1; *Error :* 2017-01-20 16:21:12,625 [277e145e-c6bc-3372-01d0-6c5b75b92d73:foreman] INFO o.a.drill.exec.work.foreman.Foreman - Query text for query id 277e145e-c6bc-3372-01d0-6c5b75b92d73: select * from hive.logindetails_all limit 1 2017-01-20 16:21:12,831 [277e145e-c6bc-3372-01d0-6c5b75b92d73:foreman] ERROR o.a.drill.exec.work.foreman.Foreman - SYSTEM ERROR: NumberFormatException: For input string: "004_" [Error Id: 53fa92e1-477e-45d2-b6f7-6eab9ef1da35 on prod-hadoop-101.bom-prod.aws.games24x7.com:31010] org.apache.drill.common.exceptions.UserException: SYSTEM ERROR: NumberFormatException: For input string: "004_" [Error Id: 53fa92e1-477e-45d2-b6f7-6eab9ef1da35 on prod-hadoop-101.bom-prod.aws.games24x7.com:31010] at org.apache.drill.common.exceptions.UserException$Builder.build(UserException.java:543) ~[drill-common-1.9.0.jar:1.9.0] at org.apache.drill.exec.work.foreman.Foreman$ForemanResult.close(Foreman.java:825) [drill-java-exec-1.9.0.jar:1.9.0] at org.apache.drill.exec.work.foreman.Foreman.moveToState(Foreman.java:935) [drill-java-exec-1.9.0.jar:1.9.0] at org.apache.drill.exec.work.foreman.Foreman.run(Foreman.java:281) [drill-java-exec-1.9.0.jar:1.9.0] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [na:1.8.0_72] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [na:1.8.0_72] at java.lang.Thread.run(Thread.java:745) [na:1.8.0_72] Caused by: org.apache.drill.exec.work.foreman.ForemanException: Unexpected exception during fragment initialization: Internal error: Error while applying rule DrillPushProjIntoScan, args [rel#4220197:LogicalProject.NONE.ANY([]).[](input=rel#4220196:Subset#0.ENUMERABLE.ANY([]).[],sid=$0,channel_id=$1,c_t=$2,l_t=$3,login_date=$4), rel#4220181:EnumerableTableScan.ENUMERABLE.ANY([]).[](table=[hive, logindetails_all])] ... 4 common frames omitted Caused by: java.lang.AssertionError: Internal error: Error while applying rule DrillPushProjIntoScan, args [rel#4220197:LogicalProject.NONE.ANY([]).[](input=rel#4220196:Subset#0.ENUMERABLE.ANY([]).[],sid=$0,channel_id=$1,c_t=$2,l_t=$3,login_date=$4), rel#4220181:EnumerableTableScan.ENUMERABLE.ANY([]).[](table=[hive, logindetails_all])] at org.apache.calcite.util.Util.newInternal(Util.java:792) ~[calcite-core-1.4.0-drill-r19.jar:1.4.0-drill-r19] at org.apache.calcite.plan.volcano.VolcanoRuleCall.onMatch(VolcanoRuleCall.java:251) ~[calcite-core-1.4.0-drill-r19.jar:1.4.0-drill-r19] at org.apache.calcite.plan.volcano.VolcanoPlanner.findBestExp(VolcanoPlanner.java:808) ~[calcite-core-1.4.0-drill-r19.jar:1.4.0-drill-r19] at org.apache.calcite.tools.Programs$RuleSetProgram.run(Programs.java:303) ~[calcite-core-1.4.0-drill-r19.jar:1.4.0-drill-r19] at org.apache.drill.exec.planner.sql.handlers.DefaultSqlHandler.transform(DefaultSqlHandler.java:404) ~[drill-java-exec-1.9.0.jar:1.9.0] at org.apache.drill.exec.planner.sql.handlers.DefaultSqlHandler.transform(DefaultSqlHandler.java:343) ~[drill-java-exec-1.9.0.jar:1.9.0] at org.apache.drill.exec.planner.sql.handlers.DefaultSqlHandler.convertToDrel(DefaultSqlHandler.java:240) ~[drill-java-exec-1.9.0.jar:1.9.0] at org.apache.drill.exec.planner.sql.handlers.DefaultSqlHandler.convertToDrel(DefaultSqlHandler.java:290) ~[drill-java-exec-1.9.0.jar:1.9.0] at org.apache.drill.exec.planner.sql.handlers.DefaultSqlHandler.getPlan(DefaultSqlHandler.java:168) ~[drill-java-exec-1.9.0.jar:1.9.0] at org.apache.drill.exec.planner.sql.DrillSqlWorker.getPhysicalPlan(DrillSqlWorker.java:123) ~[drill-java-exec-1.9.0.jar:1.9.0] at org.apache.drill.exec.planner.sql.DrillSqlWorker.getPlan(DrillSqlWorker.java:97) ~[drill-java-exec-1.9.0.jar:1.9.0] at org.apache.drill.exec.work.foreman.Foreman.runSQL(Foreman.java:1008) [drill-java-exec-1.9.0.jar:1.9.0] at org.apache.drill.exec.work.foreman.Foreman.run(Foreman.java:264) [drill-java-exec-1.9.0.jar:1.9.0] ... 3 common frames omitted Caused by: java.lang.AssertionError: Internal error: Error occurred while applying rule DrillPushProjIntoScan at