diff --git druid-handler/src/java/org/apache/hadoop/hive/druid/io/DruidRecordWriter.java druid-handler/src/java/org/apache/hadoop/hive/druid/io/DruidRecordWriter.java index d1f0d985bc..400262a107 100644 --- druid-handler/src/java/org/apache/hadoop/hive/druid/io/DruidRecordWriter.java +++ druid-handler/src/java/org/apache/hadoop/hive/druid/io/DruidRecordWriter.java @@ -181,7 +181,7 @@ private SegmentIdentifier getSegmentIdentifierAndMaybePush(long truncatedTime) { private void pushSegments(List segmentsToPush) { try { SegmentsAndMetadata segmentsAndMetadata = appenderator - .push(segmentsToPush, committerSupplier.get()).get(); + .push(segmentsToPush, committerSupplier.get(), false).get(); final HashSet pushedSegmentIdentifierHashSet = new HashSet<>(); for (DataSegment pushedSegment : segmentsAndMetadata.getSegments()) { diff --git pom.xml pom.xml index 28ad152545..604ee76f17 100644 --- pom.xml +++ pom.xml @@ -143,7 +143,7 @@ 10.14.1.0 3.1.0 0.1.2 - 0.12.0 + 0.12.1 1.2.0-3f79e055 19.0 2.4.11