diff --git common/src/java/org/apache/hadoop/hive/common/ServerUtils.java common/src/java/org/apache/hadoop/hive/common/ServerUtils.java index b44f92f..af4e9b2 100644 --- common/src/java/org/apache/hadoop/hive/common/ServerUtils.java +++ common/src/java/org/apache/hadoop/hive/common/ServerUtils.java @@ -65,5 +65,16 @@ public static InetAddress getHostAddress(String hostname) throws UnknownHostExce } return serverIPAddress; } + /** + * @return name of current host + */ + public static String hostname() { + try { + return InetAddress.getLocalHost().getHostName(); + } catch (UnknownHostException e) { + LOG.error("Unable to resolve my host name " + e.getMessage()); + throw new RuntimeException(e); + } + } } diff --git hcatalog/src/test/e2e/templeton/deployers/config/hive/hive-site.mysql.xml hcatalog/src/test/e2e/templeton/deployers/config/hive/hive-site.mysql.xml index 415caf4..36bae6c 100644 --- hcatalog/src/test/e2e/templeton/deployers/config/hive/hive-site.mysql.xml +++ hcatalog/src/test/e2e/templeton/deployers/config/hive/hive-site.mysql.xml @@ -58,13 +58,14 @@ hive.exec.dynamic.partition.mode nonstrict + hive.compactor.initiator.on - false + true hive.compactor.worker.threads - 2 + 5 hive.timedout.txn.reaper.start @@ -77,9 +78,24 @@ --> hive.timedout.txn.reaper.interval - 30s + 1s + + + hive.compactor.history.reaper.interval + 1s + + + hive.compactor.cleaner.run.interval + 1s + + + hive.compactor.check.interval + 1s + + + hive.compactor.delta.num.threshold + 2 -