[CALCITE-1279] Druid "select" query gives ClassCastException
Project: http://git-wip-us.apache.org/repos/asf/calcite/repo Commit: http://git-wip-us.apache.org/repos/asf/calcite/commit/23c8e458 Tree: http://git-wip-us.apache.org/repos/asf/calcite/tree/23c8e458 Diff: http://git-wip-us.apache.org/repos/asf/calcite/diff/23c8e458 Branch: refs/heads/master Commit: 23c8e4588c2c23703cb90ad66e51b90a8a53d7df Parents: a02da27 Author: Julian Hyde <[email protected]> Authored: Wed Jun 8 12:55:22 2016 -0700 Committer: Julian Hyde <[email protected]> Committed: Wed Jun 8 17:22:29 2016 -0700 ---------------------------------------------------------------------- .../main/java/org/apache/calcite/adapter/druid/DruidQuery.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/calcite/blob/23c8e458/druid/src/main/java/org/apache/calcite/adapter/druid/DruidQuery.java ---------------------------------------------------------------------- diff --git a/druid/src/main/java/org/apache/calcite/adapter/druid/DruidQuery.java b/druid/src/main/java/org/apache/calcite/adapter/druid/DruidQuery.java index bc51e88..0a9dbec 100644 --- a/druid/src/main/java/org/apache/calcite/adapter/druid/DruidQuery.java +++ b/druid/src/main/java/org/apache/calcite/adapter/druid/DruidQuery.java @@ -399,9 +399,8 @@ public class DruidQuery extends AbstractRelNode implements BindableRel { generator.writeFieldName("pagingSpec"); generator.writeStartObject(); final int fetch = - Integer.parseInt( - CalciteConnectionProperty.DRUID_FETCH.wrap(new Properties()) - .getString()); + CalciteConnectionProperty.DRUID_FETCH.wrap(new Properties()) + .getInt(); generator.writeNumberField("threshold", fetch); generator.writeEndObject();
