Index: core/src/test/java/org/apache/hcatalog/mapreduce/TestHCatDynamicPartitioned.java =================================================================== --- core/src/test/java/org/apache/hcatalog/mapreduce/TestHCatDynamicPartitioned.java (revision 1459416) +++ core/src/test/java/org/apache/hcatalog/mapreduce/TestHCatDynamicPartitioned.java (working copy) @@ -160,6 +160,24 @@ || (ErrorType.ERROR_MOVE_FAILED == ((HCatException) exc).getErrorType()) ); } + + query = "show partitions " + tableName; + retCode = driver.run(query).getResponseCode(); + if (retCode != 0) { + throw new Exception("Error " + retCode + " running query " + query); + } + res = new ArrayList(); + driver.getResults(res); + assertEquals(NUM_PARTITIONS, res.size()); + + query = "select * from " + tableName; + retCode = driver.run(query).getResponseCode(); + if (retCode != 0) { + throw new Exception("Error " + retCode + " running query " + query); + } + res = new ArrayList(); + driver.getResults(res); + assertEquals(NUM_RECORDS, res.size()); } //TODO 1.0 miniCluster is slow this test times out, make it work Index: core/src/main/java/org/apache/hcatalog/mapreduce/FileOutputCommitterContainer.java =================================================================== --- core/src/main/java/org/apache/hcatalog/mapreduce/FileOutputCommitterContainer.java (revision 1459416) +++ core/src/main/java/org/apache/hcatalog/mapreduce/FileOutputCommitterContainer.java (working copy) @@ -681,14 +681,14 @@ // no harProcessor, regular operation updateTableSchema(client, table, jobInfo.getOutputSchema()); LOG.info("HAR not is not being used. The table {} has new partitions {}.", table.getTableName(), ptnInfos); - partitionsAdded = partitionsToAdd; - if (dynamicPartitioningUsed && (partitionsAdded.size()>0)){ + if (dynamicPartitioningUsed && (partitionsToAdd.size()>0)){ Path src = new Path(ptnRootLocation); moveTaskOutputs(fs, src, src, tblPath, true); moveTaskOutputs(fs, src, src, tblPath, false); fs.delete(src, true); } client.add_partitions(partitionsToAdd); + partitionsAdded = partitionsToAdd; } } catch (Exception e) { if (partitionsAdded.size() > 0) {