Puneet Jaiswal created CALCITE-2873:
---------------------------------------
Summary: Error accessing druid with Avatica - prepared statement
Key: CALCITE-2873
URL: https://issues.apache.org/jira/browse/CALCITE-2873
Project: Calcite
Issue Type: Bug
Components: avatica, druid
Affects Versions: 1.12.0, 1.13.0
Reporter: Puneet Jaiswal
Query execution works when I switch to Statement and hardcode the assignment.
Code:
{code:java}
String sql = "SELECT __time, host FROM canarytest WHERE (host = ?)";
PreparedStatement st = connection.prepareStatement(sql);
st.setString(1, "i-01e588977b1b23b88");
data = st.executeQuery();
while (data.next()) {
System.out.println(data.getInt("__time") + " " + data.getString("host"));
} {code}
Exception:
{code:java}
Exception in thread "main" org.apache.calcite.avatica.AvaticaSqlException:
Error -1 (00000) : while preparing SQL: SELECT __time, host FROM canarytest
WHERE (host = ?) at
org.apache.calcite.avatica.Helper.createException(Helper.java:54) at
org.apache.calcite.avatica.Helper.createException(Helper.java:41) at
org.apache.calcite.avatica.AvaticaConnection.prepareStatement(AvaticaConnection.java:358)
at
org.apache.calcite.avatica.AvaticaConnection.prepareStatement(AvaticaConnection.java:175)
at DruidTest.main(DruidTest.java:70)
org.apache.calcite.plan.RelOptPlanner$CannotPlanException: Node
[rel#1412768:Subset#2.DRUID.[]] could not be implemented; planner state:
Root: rel#1412768:Subset#2.DRUID.[] Original rel:
LogicalFilter(subset=[rel#1412768:Subset#2.DRUID.[]], condition=[=($1, ?0)]):
rowcount = 15.0, cumulative cost = {15.0 rows, 100.0 cpu, 0.0 io}, id = 1412766
LogicalProject(subset=[rel#1412765:Subset#1.NONE.[]], __time=[$0],
host=[$2]): rowcount = 100.0, cumulative cost = {100.0 rows, 200.0 cpu, 0.0
io}, id = 1412764 LogicalTableScan(subset=[rel#1412763:Subset#0.NONE.[]],
table=[[druid, canarytest]]): rowcount = 100.0, cumulative cost = {100.0 rows,
101.0 cpu, 0.0 io}, id = 1412753 Sets: Set#0, type: RecordType(TIMESTAMP(3)
__time, BIGINT count, VARCHAR host) rel#1412763:Subset#0.NONE.[], best=null,
importance=0.7290000000000001
rel#1412753:LogicalTableScan.NONE.[](table=[druid, canarytest]),
rowcount=100.0, cumulative cost={inf}
rel#1412777:DruidQueryRel.NONE.[](query={"queryType":"scan","dataSource":{"type":"table","name":"canarytest"},"intervals":{"type":"intervals","intervals":["-146136543-09-08T08:23:32.096Z/146140482-04-24T15:36:27.903Z"]},"virtualColumns":[],"resultFormat":"compactedList","batchSize":20480,"limit":9223372036854775807,"filter":null,"columns":["__time","count","host"],"legacy":false,"context":{},"descending":false,"granularity":{"type":"all"}},signature={__time:LONG,
count:LONG, host:STRING}), rowcount=1.0, cumulative cost={inf}
rel#1412781:Subset#0.DRUID.[], best=rel#1412780, importance=0.36450000000000005
rel#1412780:DruidQueryRel.DRUID.[](query={"queryType":"scan","dataSource":{"type":"table","name":"canarytest"},"intervals":{"type":"intervals","intervals":["-146136543-09-08T08:23:32.096Z/146140482-04-24T15:36:27.903Z"]},"virtualColumns":[],"resultFormat":"compactedList","batchSize":20480,"limit":9223372036854775807,"filter":null,"columns":["__time","count","host"],"legacy":false,"context":{},"descending":false,"granularity":{"type":"all"}},signature={__time:LONG,
count:LONG, host:STRING}), rowcount=1.0, cumulative cost={1.0 rows, 0.0 cpu,
0.0 io} Set#1, type: RecordType(TIMESTAMP(3) __time, VARCHAR host)
rel#1412765:Subset#1.NONE.[], best=null, importance=0.81
rel#1412764:LogicalProject.NONE.[](input=rel#1412763:Subset#0.NONE.[],__time=$0,host=$2),
rowcount=100.0, cumulative cost={inf}
rel#1412779:DruidQueryRel.NONE.[](query={"queryType":"scan","dataSource":{"type":"table","name":"canarytest"},"intervals":{"type":"intervals","intervals":["-146136543-09-08T08:23:32.096Z/146140482-04-24T15:36:27.903Z"]},"virtualColumns":[],"resultFormat":"compactedList","batchSize":20480,"limit":9223372036854775807,"filter":null,"columns":["__time","host"],"legacy":false,"context":{},"descending":false,"granularity":{"type":"all"}},signature={__time:LONG,
host:STRING}), rowcount=1.0, cumulative cost={inf}
rel#1412784:Subset#1.DRUID.[], best=rel#1412783, importance=0.405
rel#1412783:DruidQueryRel.DRUID.[](query={"queryType":"scan","dataSource":{"type":"table","name":"canarytest"},"intervals":{"type":"intervals","intervals":["-146136543-09-08T08:23:32.096Z/146140482-04-24T15:36:27.903Z"]},"virtualColumns":[],"resultFormat":"compactedList","batchSize":20480,"limit":9223372036854775807,"filter":null,"columns":["__time","host"],"legacy":false,"context":{},"descending":false,"granularity":{"type":"all"}},signature={__time:LONG,
host:STRING}), rowcount=1.0, cumulative cost={1.002 rows, 0.0 cpu, 0.0 io}
Set#2, type: RecordType(TIMESTAMP(3) __time, VARCHAR host)
rel#1412767:Subset#2.NONE.[], best=null, importance=0.9
rel#1412766:LogicalFilter.NONE.[](input=rel#1412765:Subset#1.NONE.[],condition==($1,
?0)), rowcount=15.0, cumulative cost={inf}
rel#1412773:LogicalProject.NONE.[](input=rel#1412772:Subset#3.NONE.[],__time=$0,host=$2),
rowcount=15.0, cumulative cost={inf} rel#1412768:Subset#2.DRUID.[], best=null,
importance=1.0
rel#1412769:AbstractConverter.DRUID.[](input=rel#1412767:Subset#2.NONE.[],convention=DRUID,sort=[]),
rowcount=15.0, cumulative cost={inf} Set#3, type: RecordType(TIMESTAMP(3)
__time, BIGINT count, VARCHAR host) rel#1412772:Subset#3.NONE.[], best=null,
importance=0.81
rel#1412770:LogicalFilter.NONE.[](input=rel#1412763:Subset#0.NONE.[],condition==($2,
?0)), rowcount=15.0, cumulative cost={inf} at
org.apache.calcite.plan.volcano.RelSubset$CheapestPlanReplacer.visit(RelSubset.java:437)
at
org.apache.calcite.plan.volcano.RelSubset.buildCheapestPlan(RelSubset.java:296)
at
org.apache.calcite.plan.volcano.VolcanoPlanner.findBestExp(VolcanoPlanner.java:662)
at org.apache.calcite.tools.Programs$RuleSetProgram.run(Programs.java:339) at
org.apache.calcite.tools.Programs$SequenceProgram.run(Programs.java:358) at
org.apache.calcite.prepare.PlannerImpl.transform(PlannerImpl.java:337) at
org.apache.druid.sql.calcite.planner.DruidPlanner.planWithDruidConvention(DruidPlanner.java:160)
at
org.apache.druid.sql.calcite.planner.DruidPlanner.plan(DruidPlanner.java:128)
at
org.apache.druid.sql.calcite.planner.DruidPlanner.plan(DruidPlanner.java:105)
at org.apache.druid.sql.avatica.DruidStatement.prepare(DruidStatement.java:165)
at org.apache.druid.sql.avatica.DruidMeta.prepare(DruidMeta.java:155) at
org.apache.calcite.avatica.remote.LocalService.apply(LocalService.java:195) at
org.apache.calcite.avatica.remote.Service$PrepareRequest.accept(Service.java:1216)
at
org.apache.calcite.avatica.remote.Service$PrepareRequest.accept(Service.java:1187)
at
org.apache.calcite.avatica.remote.AbstractHandler.apply(AbstractHandler.java:94)
at org.apache.calcite.avatica.remote.JsonHandler.apply(JsonHandler.java:52) at
org.apache.calcite.avatica.server.AvaticaJsonHandler.handle(AvaticaJsonHandler.java:130)
at
org.apache.druid.sql.avatica.DruidAvaticaHandler.handle(DruidAvaticaHandler.java:59)
at org.eclipse.jetty.server.handler.HandlerList.handle(HandlerList.java:61) at
org.eclipse.jetty.server.handler.StatisticsHandler.handle(StatisticsHandler.java:169)
at
org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:132)
at org.eclipse.jetty.server.Server.handle(Server.java:531) at
org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:352) at
org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:260) at
org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:281)
at org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:102) at
org.eclipse.jetty.io.ChannelEndPoint$2.run(ChannelEndPoint.java:118) at
org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.runTask(EatWhatYouKill.java:333)
at
org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.doProduce(EatWhatYouKill.java:310)
at
org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.tryProduce(EatWhatYouKill.java:168)
at
org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.run(EatWhatYouKill.java:126)
at
org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread.run(ReservedThreadExecutor.java:366)
at
org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:760)
at
org.eclipse.jetty.util.thread.QueuedThreadPool$2.run(QueuedThreadPool.java:678)
at java.lang.Thread.run(Thread.java:748) Suppressed:
org.apache.calcite.plan.RelOptPlanner$CannotPlanException: Node
[rel#1412797:Subset#6.BINDABLE.[]] could not be implemented; planner state:
Root: rel#1412797:Subset#6.BINDABLE.[] Original rel:
LogicalFilter(subset=[rel#1412797:Subset#6.BINDABLE.[]], condition=[=($1,
?0)]): rowcount = 15.0, cumulative cost = {15.0 rows, 100.0 cpu, 0.0 io}, id =
1412795 LogicalProject(subset=[rel#1412794:Subset#5.NONE.[]], __time=[$0],
host=[$2]): rowcount = 100.0, cumulative cost = {100.0 rows, 200.0 cpu, 0.0
io}, id = 1412793 LogicalTableScan(subset=[rel#1412792:Subset#4.NONE.[]],
table=[[druid, canarytest]]): rowcount = 100.0, cumulative cost = {100.0 rows,
101.0 cpu, 0.0 io}, id = 1412753 Sets: Set#4, type: RecordType(TIMESTAMP(3)
__time, BIGINT count, VARCHAR host) rel#1412792:Subset#4.NONE.[], best=null,
importance=0.7290000000000001
rel#1412753:LogicalTableScan.NONE.[](table=[druid, canarytest]),
rowcount=100.0, cumulative cost={inf}
rel#1412813:DruidQueryRel.NONE.[](query={"queryType":"scan","dataSource":{"type":"table","name":"canarytest"},"intervals":{"type":"intervals","intervals":["-146136543-09-08T08:23:32.096Z/146140482-04-24T15:36:27.903Z"]},"virtualColumns":[],"resultFormat":"compactedList","batchSize":20480,"limit":9223372036854775807,"filter":null,"columns":["__time","count","host"],"legacy":false,"context":{},"descending":false,"granularity":{"type":"all"}},signature={__time:LONG,
count:LONG, host:STRING}), rowcount=1.0, cumulative cost={inf}
rel#1412827:Subset#4.BINDABLE.[], best=null, importance=0.81
rel#1412826:InterpretableConverter.BINDABLE.[](input=rel#1412792:Subset#4.NONE.[]),
rowcount=100.0, cumulative cost={inf} Set#5, type: RecordType(TIMESTAMP(3)
__time, VARCHAR host) rel#1412794:Subset#5.NONE.[], best=null, importance=0.81
rel#1412793:LogicalProject.NONE.[](input=rel#1412792:Subset#4.NONE.[],__time=$0,host=$2),
rowcount=100.0, cumulative cost={inf}
rel#1412814:DruidQueryRel.NONE.[](query={"queryType":"scan","dataSource":{"type":"table","name":"canarytest"},"intervals":{"type":"intervals","intervals":["-146136543-09-08T08:23:32.096Z/146140482-04-24T15:36:27.903Z"]},"virtualColumns":[],"resultFormat":"compactedList","batchSize":20480,"limit":9223372036854775807,"filter":null,"columns":["__time","host"],"legacy":false,"context":{},"descending":false,"granularity":{"type":"all"}},signature={__time:LONG,
host:STRING}), rowcount=1.0, cumulative cost={inf}
rel#1412817:Subset#5.BINDABLE.[], best=null, importance=0.9
rel#1412821:InterpretableConverter.BINDABLE.[](input=rel#1412794:Subset#5.NONE.[]),
rowcount=100.0, cumulative cost={inf}
rel#1412830:BindableProject.BINDABLE.[](input=rel#1412827:Subset#4.BINDABLE.[],__time=$0,host=$2),
rowcount=100.0, cumulative cost={inf} Set#6, type: RecordType(TIMESTAMP(3)
__time, VARCHAR host) rel#1412796:Subset#6.NONE.[], best=null, importance=0.9
rel#1412795:LogicalFilter.NONE.[](input=rel#1412794:Subset#5.NONE.[],condition==($1,
?0)), rowcount=15.0, cumulative cost={inf}
rel#1412803:LogicalProject.NONE.[](input=rel#1412802:Subset#7.NONE.[],__time=$0,host=$2),
rowcount=15.0, cumulative cost={inf} rel#1412797:Subset#6.BINDABLE.[],
best=null, importance=1.0
rel#1412798:AbstractConverter.BINDABLE.[](input=rel#1412796:Subset#6.NONE.[],convention=BINDABLE,sort=[]),
rowcount=15.0, cumulative cost={inf}
rel#1412799:InterpretableConverter.BINDABLE.[](input=rel#1412796:Subset#6.NONE.[]),
rowcount=15.0, cumulative cost={inf}
rel#1412812:BindableProject.BINDABLE.[](input=rel#1412811:Subset#7.BINDABLE.[],__time=$0,host=$2),
rowcount=15.0, cumulative cost={inf}
rel#1412818:BindableFilter.BINDABLE.[[]](input=rel#1412817:Subset#5.BINDABLE.[],condition==($1,
?0)), rowcount=15.0, cumulative cost={inf} Set#7, type:
RecordType(TIMESTAMP(3) __time, BIGINT count, VARCHAR host)
rel#1412802:Subset#7.NONE.[], best=null, importance=0.81
rel#1412800:LogicalFilter.NONE.[](input=rel#1412792:Subset#4.NONE.[],condition==($2,
?0)), rowcount=15.0, cumulative cost={inf} rel#1412811:Subset#7.BINDABLE.[],
best=null, importance=0.9
rel#1412816:InterpretableConverter.BINDABLE.[](input=rel#1412802:Subset#7.NONE.[]),
rowcount=15.0, cumulative cost={inf}
rel#1412831:BindableFilter.BINDABLE.[[]](input=rel#1412827:Subset#4.BINDABLE.[],condition==($2,
?0)), rowcount=15.0, cumulative cost={inf} at
org.apache.calcite.plan.volcano.RelSubset$CheapestPlanReplacer.visit(RelSubset.java:437)
at
org.apache.calcite.plan.volcano.RelSubset.buildCheapestPlan(RelSubset.java:296)
at
org.apache.calcite.plan.volcano.VolcanoPlanner.findBestExp(VolcanoPlanner.java:662)
at org.apache.calcite.tools.Programs$RuleSetProgram.run(Programs.java:339) at
org.apache.calcite.tools.Programs$SequenceProgram.run(Programs.java:358) at
org.apache.calcite.prepare.PlannerImpl.transform(PlannerImpl.java:337) at
org.apache.druid.sql.calcite.planner.DruidPlanner.planWithBindableConvention(DruidPlanner.java:281)
at
org.apache.druid.sql.calcite.planner.DruidPlanner.plan(DruidPlanner.java:133)
... 27 more{code}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
