You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ha...@apache.org on 2018/07/12 05:50:03 UTC

hive git commit: HIVE-20094 : Update Druid to 0.12.1 version (Slim Bouguerra via Ashutosh Chauhan)

Repository: hive
Updated Branches:
  refs/heads/master 19c2ec485 -> 6ef4a990d


HIVE-20094 : Update Druid to 0.12.1 version (Slim Bouguerra via Ashutosh Chauhan)

Signed-off-by: Ashutosh Chauhan <ha...@apache.org>


Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/6ef4a990
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/6ef4a990
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/6ef4a990

Branch: refs/heads/master
Commit: 6ef4a990db9a9c3fd890b3e7f8e810e032c5ab2c
Parents: 19c2ec4
Author: Slim Bouguerra <sl...@gmail.com>
Authored: Wed Jul 11 22:48:23 2018 -0700
Committer: Ashutosh Chauhan <ha...@apache.org>
Committed: Wed Jul 11 22:48:23 2018 -0700

----------------------------------------------------------------------
 .../java/org/apache/hadoop/hive/druid/io/DruidRecordWriter.java    | 2 +-
 pom.xml                                                            | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hive/blob/6ef4a990/druid-handler/src/java/org/apache/hadoop/hive/druid/io/DruidRecordWriter.java
----------------------------------------------------------------------
diff --git a/druid-handler/src/java/org/apache/hadoop/hive/druid/io/DruidRecordWriter.java b/druid-handler/src/java/org/apache/hadoop/hive/druid/io/DruidRecordWriter.java
index d1f0d98..400262a 100644
--- a/druid-handler/src/java/org/apache/hadoop/hive/druid/io/DruidRecordWriter.java
+++ b/druid-handler/src/java/org/apache/hadoop/hive/druid/io/DruidRecordWriter.java
@@ -181,7 +181,7 @@ public class DruidRecordWriter implements RecordWriter<NullWritable, DruidWritab
   private void pushSegments(List<SegmentIdentifier> segmentsToPush) {
     try {
       SegmentsAndMetadata segmentsAndMetadata = appenderator
-              .push(segmentsToPush, committerSupplier.get()).get();
+              .push(segmentsToPush, committerSupplier.get(), false).get();
       final HashSet<String> pushedSegmentIdentifierHashSet = new HashSet<>();
 
       for (DataSegment pushedSegment : segmentsAndMetadata.getSegments()) {

http://git-wip-us.apache.org/repos/asf/hive/blob/6ef4a990/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index 28ad152..604ee76 100644
--- a/pom.xml
+++ b/pom.xml
@@ -143,7 +143,7 @@
     <derby.version>10.14.1.0</derby.version>
     <dropwizard.version>3.1.0</dropwizard.version>
     <dropwizard-metrics-hadoop-metrics2-reporter.version>0.1.2</dropwizard-metrics-hadoop-metrics2-reporter.version>
-    <druid.version>0.12.0</druid.version>
+    <druid.version>0.12.1</druid.version>
     <flatbuffers.version>1.2.0-3f79e055</flatbuffers.version>
     <guava.version>19.0</guava.version>
     <groovy.version>2.4.11</groovy.version>