Repository: hive Updated Branches: refs/heads/master d8059d8c0 -> 3934c1886
Revert "HIVE-10685: Alter table concatenate oparetor will cause duplicate data (guoliming reviewed by Prasanth Jayachandran)" This reverts commit d0c68b29e3b6c57a5d5606c22f938631915274d9. Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/4f28731c Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/4f28731c Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/4f28731c Branch: refs/heads/master Commit: 4f28731cc0da9b2e3a886c49bc59a63f9e332ff8 Parents: d8059d8 Author: Prasanth Jayachandran <[email protected]> Authored: Mon Jun 15 15:22:18 2015 -0700 Committer: Prasanth Jayachandran <[email protected]> Committed: Mon Jun 15 15:22:18 2015 -0700 ---------------------------------------------------------------------- .../hive/ql/io/orc/OrcFileStripeMergeRecordReader.java | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/4f28731c/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcFileStripeMergeRecordReader.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcFileStripeMergeRecordReader.java b/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcFileStripeMergeRecordReader.java index 20c4d31..603b75a 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcFileStripeMergeRecordReader.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcFileStripeMergeRecordReader.java @@ -18,16 +18,16 @@ package org.apache.hadoop.hive.ql.io.orc; -import java.io.IOException; -import java.util.Iterator; -import java.util.List; - import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; import org.apache.hadoop.mapred.FileSplit; import org.apache.hadoop.mapred.RecordReader; +import java.io.IOException; +import java.util.Iterator; +import java.util.List; + public class OrcFileStripeMergeRecordReader implements RecordReader<OrcFileKeyWrapper, OrcFileValueWrapper> { @@ -79,7 +79,7 @@ public class OrcFileStripeMergeRecordReader implements // if stripe offset is outside the split boundary then ignore the current // stripe as it will be handled by some other mapper. if (si.getOffset() >= start && si.getOffset() < end) { - valueWrapper.setStripeStatistics(stripeStatistics.get(stripeIdx)); + valueWrapper.setStripeStatistics(stripeStatistics.get(stripeIdx++)); valueWrapper.setStripeInformation(si); if (!iter.hasNext()) { valueWrapper.setLastStripeInFile(true); @@ -94,7 +94,6 @@ public class OrcFileStripeMergeRecordReader implements } else { continue; } - stripeIdx++; return true; }
