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
commit 998be10e21aa1de58b9d0f48940bc216ba66dbde Author: Zoltan Haindrich <k...@rxd.hu> AuthorDate: Wed Apr 22 08:06:48 2020 +0000 HIVE-23246: Reduce MiniDruidCluster memory requeirements (Zoltan Haindrich reviewed by Peter Vary) Signed-off-by: Zoltan Haindrich <zhaindr...@cloudera.com> --- .../java/org/apache/hive/druid/MiniDruidCluster.java | 20 +++++++++----------- 1 file changed, 9 insertions(+), 11 deletions(-) diff --git a/itests/qtest-druid/src/main/java/org/apache/hive/druid/MiniDruidCluster.java b/itests/qtest-druid/src/main/java/org/apache/hive/druid/MiniDruidCluster.java index 8081595..0fb63ce 100644 --- a/itests/qtest-druid/src/main/java/org/apache/hive/druid/MiniDruidCluster.java +++ b/itests/qtest-druid/src/main/java/org/apache/hive/druid/MiniDruidCluster.java @@ -60,7 +60,7 @@ public class MiniDruidCluster extends AbstractService { "druid.storage.type", "hdfs", "druid.processing.buffer.sizeBytes", - "213870912", + "10485760", "druid.processing.numThreads", "2", "druid.worker.capacity", @@ -72,16 +72,14 @@ public class MiniDruidCluster extends AbstractService { private static final Map<String, String> COMMON_COORDINATOR_INDEXER = - ImmutableMap.of("druid.indexer.logs.type", - "file", - "druid.coordinator.asOverlord.enabled", - "true", - "druid.coordinator.asOverlord.overlordService", - "druid/overlord", - "druid.coordinator.period", - "PT2S", - "druid.manager.segments.pollDuration", - "PT2S"); + ImmutableMap.<String,String>builder() + .put("druid.indexer.logs.type", "file") + .put("druid.coordinator.asOverlord.enabled", "true") + .put("druid.coordinator.asOverlord.overlordService", "druid/overlord") + .put("druid.coordinator.period", "PT2S") + .put("druid.manager.segments.pollDuration", "PT2S") + .put("druid.indexer.runner.javaOpts", "-Xmx512m") + .build(); private static final int MIN_PORT_NUMBER = 60000; private static final int MAX_PORT_NUMBER = 65535;