diff --git ql/src/java/org/apache/hadoop/hive/ql/io/AcidUtils.java ql/src/java/org/apache/hadoop/hive/ql/io/AcidUtils.java index 30db513..6984def 100644 --- ql/src/java/org/apache/hadoop/hive/ql/io/AcidUtils.java +++ ql/src/java/org/apache/hadoop/hive/ql/io/AcidUtils.java @@ -368,6 +368,9 @@ else if(statementId != parsedDelta.statementId) { public static Path[] deserializeDeltas(Path root, final List deltas) throws IOException { List results = new ArrayList(deltas.size()); for(AcidInputFormat.DeltaMetaData dmd : deltas) { + if (dmd.getStmtIds() == null) { + continue; + } if(dmd.getStmtIds().isEmpty()) { results.add(new Path(root, deltaSubdir(dmd.getMinTxnId(), dmd.getMaxTxnId()))); continue;