You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by se...@apache.org on 2018/06/07 19:01:03 UTC
[2/2] hive git commit: HIVE-19418 : add background stats updater
similar to compactor (Sergey Shelukhin, reviewed by Ashutosh Chauhan) ADDENDUM
HIVE-19418 : add background stats updater similar to compactor (Sergey Shelukhin, reviewed by Ashutosh Chauhan) ADDENDUM
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/9ac67e32
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/9ac67e32
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/9ac67e32
Branch: refs/heads/branch-3
Commit: 9ac67e32578b9903e6707d432496f7eade88003c
Parents: 7899fac
Author: sergey <se...@apache.org>
Authored: Thu Jun 7 11:56:49 2018 -0700
Committer: sergey <se...@apache.org>
Committed: Thu Jun 7 11:57:17 2018 -0700
----------------------------------------------------------------------
.../hive/ql/stats/TestStatsUpdaterThread.java | 18 +++++++++---------
1 file changed, 9 insertions(+), 9 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/9ac67e32/ql/src/test/org/apache/hadoop/hive/ql/stats/TestStatsUpdaterThread.java
----------------------------------------------------------------------
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 d0b41f3..14f86ea 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
@@ -97,7 +97,7 @@ public class TestStatsUpdaterThread {
executeQuery("drop table simple_stats3");
}
- @Test(timeout=20000)
+ @Test(timeout=40000)
public void testSimpleUpdateWithThreads() throws Exception {
StatsUpdaterThread su = createUpdater();
su.startWorkers();
@@ -114,7 +114,7 @@ public class TestStatsUpdaterThread {
msClient.close();
}
- @Test(timeout=20000)
+ @Test(timeout=40000)
public void testMultipleTables() throws Exception {
StatsUpdaterThread su = createUpdater();
IMetaStoreClient msClient = new HiveMetaStoreClient(hiveConf);
@@ -140,7 +140,7 @@ public class TestStatsUpdaterThread {
msClient.close();
}
- @Test(timeout=20000)
+ @Test(timeout=40000)
public void testExistingOnly() throws Exception {
hiveConf.set(MetastoreConf.ConfVars.STATS_AUTO_UPDATE.getVarname(), "existing");
StatsUpdaterThread su = createUpdater();
@@ -162,7 +162,7 @@ public class TestStatsUpdaterThread {
msClient.close();
}
- @Test(timeout=60000)
+ @Test(timeout=80000)
public void testQueueingWithThreads() throws Exception {
final int PART_COUNT = 12;
hiveConf.setInt(MetastoreConf.ConfVars.BATCH_RETRIEVE_MAX.getVarname(), 5);
@@ -193,7 +193,7 @@ public class TestStatsUpdaterThread {
msClient.close();
}
- @Test(timeout=20000)
+ @Test(timeout=40000)
public void testAllPartitions() throws Exception {
final int PART_COUNT = 3;
StatsUpdaterThread su = createUpdater();
@@ -216,7 +216,7 @@ public class TestStatsUpdaterThread {
msClient.close();
}
- @Test(timeout=20000)
+ @Test(timeout=40000)
public void testPartitionSubset() throws Exception {
final int NONSTAT_PART_COUNT = 3;
StatsUpdaterThread su = createUpdater();
@@ -251,7 +251,7 @@ public class TestStatsUpdaterThread {
msClient.close();
}
- @Test(timeout=20000)
+ @Test(timeout=40000)
public void testPartitionsWithDifferentColsAll() throws Exception {
StatsUpdaterThread su = createUpdater();
IMetaStoreClient msClient = new HiveMetaStoreClient(hiveConf);
@@ -280,7 +280,7 @@ public class TestStatsUpdaterThread {
}
- @Test(timeout=20000)
+ @Test(timeout=45000)
public void testPartitionsWithDifferentColsExistingOnly() throws Exception {
hiveConf.set(MetastoreConf.ConfVars.STATS_AUTO_UPDATE.getVarname(), "existing");
StatsUpdaterThread su = createUpdater();
@@ -316,7 +316,7 @@ public class TestStatsUpdaterThread {
msClient.close();
}
- @Test(timeout=20000)
+ @Test(timeout=40000)
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);