This is an automated email from the ASF dual-hosted git repository. kgyrtkirk pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/hive.git
The following commit(s) were added to refs/heads/master by this push: new 9d943c3 put TestTxnHandler#allocateNextWriteIdRetriesAfterDetectingConflictingConcurrentInsert on ignore; raise some timeouts 9d943c3 is described below commit 9d943c31a6f9e9018e6a6c9eff57fe561b87c815 Author: Zoltan Haindrich <k...@rxd.hu> AuthorDate: Sun Jun 7 09:45:51 2020 +0000 put TestTxnHandler#allocateNextWriteIdRetriesAfterDetectingConflictingConcurrentInsert on ignore; raise some timeouts --- .../hadoop/hive/metastore/txn/TestTxnHandler.java | 1 + .../hive/ql/stats/TestStatsUpdaterThread.java | 24 +++++++++++----------- 2 files changed, 13 insertions(+), 12 deletions(-) diff --git a/ql/src/test/org/apache/hadoop/hive/metastore/txn/TestTxnHandler.java b/ql/src/test/org/apache/hadoop/hive/metastore/txn/TestTxnHandler.java index 569605f..3d00bf7 100644 --- a/ql/src/test/org/apache/hadoop/hive/metastore/txn/TestTxnHandler.java +++ b/ql/src/test/org/apache/hadoop/hive/metastore/txn/TestTxnHandler.java @@ -1756,6 +1756,7 @@ public class TestTxnHandler { } @Test + @Ignore("unstable HIVE-23630") public void allocateNextWriteIdRetriesAfterDetectingConflictingConcurrentInsert() throws Exception { String dbName = "abc"; String tableName = "def"; diff --git a/ql/src/test/org/apache/hadoop/hive/ql/stats/TestStatsUpdaterThread.java b/ql/src/test/org/apache/hadoop/hive/ql/stats/TestStatsUpdaterThread.java index afe6070..771ff17 100644 --- a/ql/src/test/org/apache/hadoop/hive/ql/stats/TestStatsUpdaterThread.java +++ b/ql/src/test/org/apache/hadoop/hive/ql/stats/TestStatsUpdaterThread.java @@ -102,7 +102,7 @@ public class TestStatsUpdaterThread { executeQuery("drop table simple_stats3"); } - @Test(timeout=40000) + @Test(timeout=80000) public void testSimpleUpdateWithThreads() throws Exception { StatsUpdaterThread su = createUpdater(); su.startWorkers(); @@ -119,7 +119,7 @@ public class TestStatsUpdaterThread { msClient.close(); } - @Test(timeout=40000) + @Test(timeout=80000) public void testMultipleTables() throws Exception { StatsUpdaterThread su = createUpdater(); IMetaStoreClient msClient = new HiveMetaStoreClient(hiveConf); @@ -145,7 +145,7 @@ public class TestStatsUpdaterThread { msClient.close(); } - @Test(timeout=80000) + @Test(timeout=160000) public void testTxnTable() throws Exception { StatsUpdaterThread su = createUpdater(); IMetaStoreClient msClient = new HiveMetaStoreClient(hiveConf); @@ -318,7 +318,7 @@ public class TestStatsUpdaterThread { msClient.close(); } - @Test(timeout=40000) + @Test(timeout=80000) public void testExistingOnly() throws Exception { hiveConf.set(MetastoreConf.ConfVars.STATS_AUTO_UPDATE.getVarname(), "existing"); StatsUpdaterThread su = createUpdater(); @@ -340,7 +340,7 @@ public class TestStatsUpdaterThread { msClient.close(); } - @Test(timeout=80000) + @Test(timeout=160000) public void testQueueingWithThreads() throws Exception { final int PART_COUNT = 12; hiveConf.setInt(MetastoreConf.ConfVars.BATCH_RETRIEVE_MAX.getVarname(), 5); @@ -371,7 +371,7 @@ public class TestStatsUpdaterThread { msClient.close(); } - @Test(timeout=40000) + @Test(timeout=80000) public void testAllPartitions() throws Exception { final int PART_COUNT = 3; StatsUpdaterThread su = createUpdater(); @@ -394,7 +394,7 @@ public class TestStatsUpdaterThread { msClient.close(); } - @Test(timeout=40000) + @Test(timeout=80000) public void testPartitionSubset() throws Exception { final int NONSTAT_PART_COUNT = 3; StatsUpdaterThread su = createUpdater(); @@ -429,7 +429,7 @@ public class TestStatsUpdaterThread { msClient.close(); } - @Test(timeout=40000) + @Test(timeout=80000) public void testPartitionsWithDifferentColsAll() throws Exception { StatsUpdaterThread su = createUpdater(); IMetaStoreClient msClient = new HiveMetaStoreClient(hiveConf); @@ -458,7 +458,7 @@ public class TestStatsUpdaterThread { } - @Test(timeout=45000) + @Test(timeout=80000) public void testPartitionsWithDifferentColsExistingOnly() throws Exception { hiveConf.set(MetastoreConf.ConfVars.STATS_AUTO_UPDATE.getVarname(), "existing"); StatsUpdaterThread su = createUpdater(); @@ -494,7 +494,7 @@ public class TestStatsUpdaterThread { msClient.close(); } - @Test(timeout=40000) + @Test(timeout=80000) public void testParallelOps() throws Exception { // Set high worker count so we get a longer queue. hiveConf.setInt(MetastoreConf.ConfVars.STATS_AUTO_UPDATE_WORKER_COUNT.getVarname(), 4); @@ -545,14 +545,14 @@ public class TestStatsUpdaterThread { // A table which is target of replication should not be queued for stats update, and hence its // stats state should not change. - @Test(timeout=40000) + @Test(timeout=80000) public void testNoStatsUpdateForSimpleReplTable() throws Exception { testNoStatsUpdateForReplTable("simple", ""); } // A table which is target of replication should not be queued for stats update, and hence its // stats state should not change. - @Test(timeout=40000) + @Test(timeout=80000) public void testNoStatsUpdateForTxnReplTable() throws Exception { testNoStatsUpdateForReplTable("txn", "TBLPROPERTIES (\"transactional\"=\"true\",\"transactional_properties\"=\"insert_only\")");