diff --git a/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcRawRecordMerger.java b/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcRawRecordMerger.java index 62a1061dfd..fc7e7e1011 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcRawRecordMerger.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcRawRecordMerger.java @@ -741,10 +741,10 @@ private KeyInterval discoverOriginalKeyBounds(Reader reader, int bucket, } } if (rowOffset > 0) { - minKey = new RecordIdentifier(0, bucketProperty, rowOffset - 1); + minKey = new RecordIdentifier(tfp.syntheticWriteId, bucketProperty, rowOffset - 1); } if (!isTail) { - maxKey = new RecordIdentifier(0, bucketProperty, rowOffset + rowLength - 1); + maxKey = new RecordIdentifier(tfp.syntheticWriteId, bucketProperty, rowOffset + rowLength - 1); } return new KeyInterval(minKey, maxKey); }