You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@heron.apache.org by nw...@apache.org on 2019/02/28 22:57:03 UTC

[incubator-heron] branch master updated: Boost default maxNumInstancesPerContainer (#3200)

This is an automated email from the ASF dual-hosted git repository.

nwang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-heron.git


The following commit(s) were added to refs/heads/master by this push:
     new 0369acc  Boost default maxNumInstancesPerContainer (#3200)
0369acc is described below

commit 0369acc1e56c761b4854593d3dec4548799b0a92
Author: Xiaoyao Qian <qi...@illinois.edu>
AuthorDate: Thu Feb 28 14:56:57 2019 -0800

    Boost default maxNumInstancesPerContainer (#3200)
---
 heron/packing/src/java/org/apache/heron/packing/utils/PackingUtils.java | 2 +-
 .../packing/tests/java/org/apache/heron/packing/CommonPackingTests.java | 1 +
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/heron/packing/src/java/org/apache/heron/packing/utils/PackingUtils.java b/heron/packing/src/java/org/apache/heron/packing/utils/PackingUtils.java
index 36ede38..8390711 100644
--- a/heron/packing/src/java/org/apache/heron/packing/utils/PackingUtils.java
+++ b/heron/packing/src/java/org/apache/heron/packing/utils/PackingUtils.java
@@ -40,7 +40,7 @@ public final class PackingUtils {
   public static final ByteAmount DEFAULT_CONTAINER_RAM_PADDING = ByteAmount.fromGigabytes(1);
   public static final ByteAmount DEFAULT_CONTAINER_DISK_PADDING = ByteAmount.fromGigabytes(1);
   public static final double DEFAULT_CONTAINER_CPU_PADDING = 1.0;
-  public static final int DEFAULT_MAX_NUM_INSTANCES_PER_CONTAINER = 4;
+  public static final int DEFAULT_MAX_NUM_INSTANCES_PER_CONTAINER = 10;
 
   private PackingUtils() {
   }
diff --git a/heron/packing/tests/java/org/apache/heron/packing/CommonPackingTests.java b/heron/packing/tests/java/org/apache/heron/packing/CommonPackingTests.java
index d99ac92..9233afe 100644
--- a/heron/packing/tests/java/org/apache/heron/packing/CommonPackingTests.java
+++ b/heron/packing/tests/java/org/apache/heron/packing/CommonPackingTests.java
@@ -71,6 +71,7 @@ public abstract class CommonPackingTests {
     // object Config and Topology objects. This is typically fine for packing tests since they don't
     // access the protobuf values.
     this.topologyConfig = new org.apache.heron.api.Config();
+    this.topologyConfig.setTopologyContainerMaxNumInstances(4);
     this.topology = getTopology(spoutParallelism, boltParallelism, topologyConfig);
 
     Config config = PackingTestUtils.newTestConfig(this.topology);