You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@calcite.apache.org by jh...@apache.org on 2018/08/29 21:59:00 UTC
calcite git commit: [CALCITE-2483] Druid adapter,
when querying Druid segment metadata,
throws when row number is larger than Integer.MAX_VALUE (Hongze Zhang)
Repository: calcite
Updated Branches:
refs/heads/master 1c30edca1 -> 0d707e4e4
[CALCITE-2483] Druid adapter, when querying Druid segment metadata, throws when row number is larger than Integer.MAX_VALUE (Hongze Zhang)
Close apache/calcite#799
Project: http://git-wip-us.apache.org/repos/asf/calcite/repo
Commit: http://git-wip-us.apache.org/repos/asf/calcite/commit/0d707e4e
Tree: http://git-wip-us.apache.org/repos/asf/calcite/tree/0d707e4e
Diff: http://git-wip-us.apache.org/repos/asf/calcite/diff/0d707e4e
Branch: refs/heads/master
Commit: 0d707e4e4e5840776670d57b1b7d61ca6d963e13
Parents: 1c30edc
Author: hongzezhang <ho...@tencent.com>
Authored: Wed Aug 22 15:50:37 2018 +0800
Committer: Julian Hyde <jh...@apache.org>
Committed: Wed Aug 29 14:58:47 2018 -0700
----------------------------------------------------------------------
.../org/apache/calcite/adapter/druid/DruidConnectionImpl.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/calcite/blob/0d707e4e/druid/src/main/java/org/apache/calcite/adapter/druid/DruidConnectionImpl.java
----------------------------------------------------------------------
diff --git a/druid/src/main/java/org/apache/calcite/adapter/druid/DruidConnectionImpl.java b/druid/src/main/java/org/apache/calcite/adapter/druid/DruidConnectionImpl.java
index 175a16d..1b85b39 100644
--- a/druid/src/main/java/org/apache/calcite/adapter/druid/DruidConnectionImpl.java
+++ b/druid/src/main/java/org/apache/calcite/adapter/druid/DruidConnectionImpl.java
@@ -719,8 +719,8 @@ class DruidConnectionImpl implements DruidConnection {
public String id;
public List<String> intervals;
public Map<String, JsonColumn> columns;
- public int size;
- public int numRows;
+ public long size;
+ public long numRows;
public Map<String, JsonAggregator> aggregators;
}