Repository: hive Updated Branches: refs/heads/master 2f40ac3aa -> dcfb1ed27
HIVE-15046: Multiple fixes for Druid handler (Jesus Camacho Rodriguez, reviewed by Ashutosh Chauhan) (addendum) Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/dcfb1ed2 Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/dcfb1ed2 Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/dcfb1ed2 Branch: refs/heads/master Commit: dcfb1ed2788a4c497bc251ab777c2d04652fa20c Parents: 2f40ac3 Author: Jesus Camacho Rodriguez <[email protected]> Authored: Thu Oct 27 11:56:15 2016 -0400 Committer: Jesus Camacho Rodriguez <[email protected]> Committed: Thu Oct 27 11:56:33 2016 -0400 ---------------------------------------------------------------------- .../hadoop/hive/druid/HiveDruidQueryBasedInputFormat.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/dcfb1ed2/druid-handler/src/java/org/apache/hadoop/hive/druid/HiveDruidQueryBasedInputFormat.java ---------------------------------------------------------------------- diff --git a/druid-handler/src/java/org/apache/hadoop/hive/druid/HiveDruidQueryBasedInputFormat.java b/druid-handler/src/java/org/apache/hadoop/hive/druid/HiveDruidQueryBasedInputFormat.java index cc4a8ef..787cd52 100644 --- a/druid-handler/src/java/org/apache/hadoop/hive/druid/HiveDruidQueryBasedInputFormat.java +++ b/druid-handler/src/java/org/apache/hadoop/hive/druid/HiveDruidQueryBasedInputFormat.java @@ -254,7 +254,7 @@ public class HiveDruidQueryBasedInputFormat extends InputFormat<NullWritable, Dr } intervals.add(new Interval(timeList.get(0).getValue().getMinTime().getMillis(), - timeList.get(0).getValue().getMaxTime().getMillis())); + timeList.get(0).getValue().getMaxTime().getMillis(), ISOChronology.getInstanceUTC())); } else { intervals.addAll(query.getIntervals()); } @@ -289,13 +289,13 @@ public class HiveDruidQueryBasedInputFormat extends InputFormat<NullWritable, Dr final long expectedRange = rangeSize - currTime; if (interval.getEndMillis() - startTime >= expectedRange) { endTime = startTime + expectedRange; - currentIntervals.add(new Interval(startTime, endTime)); + currentIntervals.add(new Interval(startTime, endTime, ISOChronology.getInstanceUTC())); startTime = endTime; currTime = 0; break; } endTime = interval.getEndMillis(); - currentIntervals.add(new Interval(startTime, endTime)); + currentIntervals.add(new Interval(startTime, endTime, ISOChronology.getInstanceUTC())); currTime += (endTime - startTime); startTime = intervals.get(++posIntervals).getStartMillis(); }
