Index: shims/src/common-secure/java/org/apache/hadoop/hive/shims/HadoopShimsSecure.java =================================================================== --- shims/src/common-secure/java/org/apache/hadoop/hive/shims/HadoopShimsSecure.java (revision 1229510) +++ shims/src/common-secure/java/org/apache/hadoop/hive/shims/HadoopShimsSecure.java (working copy) @@ -384,11 +384,11 @@ super.setMaxSplitSize(minSize); } - CombineFileSplit[] splits = (CombineFileSplit[]) super.getSplits(job, numSplits); + InputSplit[] splits = (InputSplit[]) super.getSplits(job, numSplits); InputSplitShim[] isplits = new InputSplitShim[splits.length]; for (int pos = 0; pos < splits.length; pos++) { - isplits[pos] = new InputSplitShim(splits[pos]); + isplits[pos] = new InputSplitShim((CombineFileSplit)splits[pos]); } return isplits; Index: ql/src/java/org/apache/hadoop/hive/ql/io/SchemaAwareCompressionInputStream.java =================================================================== --- ql/src/java/org/apache/hadoop/hive/ql/io/SchemaAwareCompressionInputStream.java (revision 1229510) +++ ql/src/java/org/apache/hadoop/hive/ql/io/SchemaAwareCompressionInputStream.java (working copy) @@ -29,7 +29,7 @@ */ public abstract class SchemaAwareCompressionInputStream extends CompressionInputStream { - protected SchemaAwareCompressionInputStream(InputStream in) { + protected SchemaAwareCompressionInputStream(InputStream in) throws java.io.IOException { super(in); }