diff --git llap-server/src/java/org/apache/hadoop/hive/llap/daemon/impl/LlapDaemon.java llap-server/src/java/org/apache/hadoop/hive/llap/daemon/impl/LlapDaemon.java index 1801212..7959945 100644 --- llap-server/src/java/org/apache/hadoop/hive/llap/daemon/impl/LlapDaemon.java +++ llap-server/src/java/org/apache/hadoop/hive/llap/daemon/impl/LlapDaemon.java @@ -195,7 +195,6 @@ private long getTotalHeapSize() { // in the usable space. long total = 0; - MemoryMXBean m = ManagementFactory.getMemoryMXBean(); for (MemoryPoolMXBean mp : ManagementFactory.getMemoryPoolMXBeans()) { long sz = mp.getUsage().getMax(); if (mp.getName().contains("Survivor")) { @@ -205,6 +204,8 @@ private long getTotalHeapSize() { total += sz; } } + // round up to the next MB + total += (total % (1024*1024)); return total; } diff --git llap-server/src/main/resources/package.py llap-server/src/main/resources/package.py index ae501cf..f410730 100644 --- llap-server/src/main/resources/package.py +++ llap-server/src/main/resources/package.py @@ -33,7 +33,7 @@ def __init__(self, config): else: # do not mess with user input c = size - self.container_size = size + self.container_size = c self.container_cores = self.cores self.heap_size = h