HIVE-23539 : Optimize data copy during repl load operation for HDFS b…

…ased staging location - fixed tests
apache · Jun 16, 2020 · ea0c6c8 · ea0c6c8
1 parent 86c860b
commit ea0c6c8
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/...nit/src/test/java/org/apache/hadoop/hive/ql/parse/TestReplicationScenariosAcidTables.java b/...nit/src/test/java/org/apache/hadoop/hive/ql/parse/TestReplicationScenariosAcidTables.java
@@ -1539,15 +1539,14 @@ public void testCheckPointingWithSourceTableDataInserted() throws Throwable {
             .run("insert into t2 values (24)")
             .run("insert into t1 values (4)")
             .dump(primaryDbName, dumpClause);
-
+    assertEquals(modifiedTimeTable1CopyFile, fs.listStatus(tablet1Path)[0].getModificationTime());
+    assertTrue(modifiedTimeTable2 < fs.getFileStatus(tablet2Path).getModificationTime());
     replica.load(replicatedDbName, primaryDbName)
             .run("use " + replicatedDbName)
             .run("select * from t1")
             .verifyResults(new String[]{"1", "2", "3", "4"})
             .run("select * from t2")
             .verifyResults(new String[]{"11", "21", "13", "24"});
-    assertEquals(modifiedTimeTable1CopyFile, fs.listStatus(tablet1Path)[0].getModificationTime());
-    assertTrue(modifiedTimeTable2 < fs.getFileStatus(tablet2Path).getModificationTime());
   }
 
   @Test
@@ -1596,6 +1595,10 @@ public void testCheckPointingWithNewTablesAdded() throws Throwable {
             .run("insert into t3 values (3)")
             .dump(primaryDbName, dumpClause);
 
+    assertEquals(modifiedTimeTable1, fs.getFileStatus(tablet1Path).getModificationTime());
+    assertEquals(modifiedTimeTable1CopyFile, fs.listStatus(tablet1Path)[0].getModificationTime());
+    assertTrue(modifiedTimeTable2 < fs.getFileStatus(tablet2Path).getModificationTime());
+
     replica.load(replicatedDbName, primaryDbName)
             .run("use " + replicatedDbName)
             .run("select * from t1")
@@ -1606,9 +1609,6 @@ public void testCheckPointingWithNewTablesAdded() throws Throwable {
             .verifyResults(new String[]{"t1", "t2", "t3"})
             .run("select * from t3")
             .verifyResults(new String[]{"1", "2", "3"});
-    assertEquals(modifiedTimeTable1, fs.getFileStatus(tablet1Path).getModificationTime());
-    assertEquals(modifiedTimeTable1CopyFile, fs.listStatus(tablet1Path)[0].getModificationTime());
-    assertTrue(modifiedTimeTable2 < fs.getFileStatus(tablet2Path).getModificationTime());
   }
 
   @Test