diff --git a/itests/hive-unit/src/test/java/org/apache/hadoop/hive/ql/txn/compactor/TestCompactor.java b/itests/hive-unit/src/test/java/org/apache/hadoop/hive/ql/txn/compactor/TestCompactor.java index 95fa6641f2..4ad69a9839 100644 --- a/itests/hive-unit/src/test/java/org/apache/hadoop/hive/ql/txn/compactor/TestCompactor.java +++ b/itests/hive-unit/src/test/java/org/apache/hadoop/hive/ql/txn/compactor/TestCompactor.java @@ -915,6 +915,31 @@ private void mmTableOriginals(String format) throws Exception { msClient.close(); } + @Test + public void mmTableOriginalsDeltas() throws Exception { + String format = "TEXTFILE"; + String tblName = "mm_nonpart"; + executeStatementOnDriver("drop table if exists " + tblName, driver); + executeStatementOnDriver("CREATE TABLE " + tblName + "(a INT, b STRING) STORED AS " + + format + " TBLPROPERTIES ('transactional'='false')", driver); + + executeStatementOnDriver("INSERT INTO " + tblName + "(a,b) VALUES(1, 'foo')", driver); + executeStatementOnDriver("INSERT INTO " + tblName +" (a,b) VALUES(2, 'bar')", driver); + executeStatementOnDriver("INSERT INTO " + tblName + "(a,b) SELECT a,b FROM " + + tblName + " UNION ALL SELECT a,b FROM " + tblName, driver); + + verifyFooBarResult(tblName, 3); + + executeStatementOnDriver("ALTER TABLE " + tblName + " SET TBLPROPERTIES " + + "('transactional'='true', 'transactional_properties'='insert_only')", driver); + + verifyFooBarResult(tblName, 3); + + executeStatementOnDriver("INSERT INTO " + tblName + "(a,b) VALUES(1, 'foo')", driver); + executeStatementOnDriver("INSERT INTO " + tblName +" (a,b) VALUES(2, 'bar')", driver); + + verifyFooBarResult(tblName, 4); // todo fails here + } @Test public void mmTableBucketed() throws Exception {