You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by kg...@apache.org on 2020/06/07 09:58:34 UTC
[hive] branch master updated: put
TestTxnHandler#allocateNextWriteIdRetriesAfterDetectingConflictingConcurrentInsert
on ignore; raise some timeouts
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 <ki...@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\")");