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);