diff --git a/examples/src/java/org/apache/heron/examples/api/ExampleResources.java b/examples/src/java/org/apache/heron/examples/api/ExampleResources.java index c5c66a44e25..be92dea1650 100644 --- a/examples/src/java/org/apache/heron/examples/api/ExampleResources.java +++ b/examples/src/java/org/apache/heron/examples/api/ExampleResources.java @@ -23,7 +23,7 @@ public final class ExampleResources { - static final long COMPONENT_RAM_MB = 512; + static final long COMPONENT_RAM_MB = 1024; static ByteAmount getComponentRam() { return ByteAmount.fromMegabytes(COMPONENT_RAM_MB); diff --git a/examples/src/java/org/apache/heron/examples/api/StatefulWordCountTopology.java b/examples/src/java/org/apache/heron/examples/api/StatefulWordCountTopology.java index 6208727e39e..7ed35627437 100644 --- a/examples/src/java/org/apache/heron/examples/api/StatefulWordCountTopology.java +++ b/examples/src/java/org/apache/heron/examples/api/StatefulWordCountTopology.java @@ -205,9 +205,9 @@ public static void main(String[] args) throws AlreadyAliveException, InvalidTopo // configure component resources conf.setComponentRam("word", - ByteAmount.fromMegabytes(ExampleResources.COMPONENT_RAM_MB * 2)); + ByteAmount.fromMegabytes(ExampleResources.COMPONENT_RAM_MB)); conf.setComponentRam("consumer", - ByteAmount.fromMegabytes(ExampleResources.COMPONENT_RAM_MB * 2)); + ByteAmount.fromMegabytes(ExampleResources.COMPONENT_RAM_MB)); // configure container resources conf.setContainerDiskRequested( diff --git a/examples/src/java/org/apache/heron/examples/api/WordCountTopology.java b/examples/src/java/org/apache/heron/examples/api/WordCountTopology.java index 0a919d86aab..5991cfd035e 100644 --- a/examples/src/java/org/apache/heron/examples/api/WordCountTopology.java +++ b/examples/src/java/org/apache/heron/examples/api/WordCountTopology.java @@ -184,9 +184,9 @@ public static void main(String[] args) throws AlreadyAliveException, InvalidTopo // configure component resources conf.setComponentRam("word", - ByteAmount.fromMegabytes(ExampleResources.COMPONENT_RAM_MB * 2)); + ByteAmount.fromMegabytes(ExampleResources.COMPONENT_RAM_MB)); conf.setComponentRam("consumer", - ByteAmount.fromMegabytes(ExampleResources.COMPONENT_RAM_MB * 2)); + ByteAmount.fromMegabytes(ExampleResources.COMPONENT_RAM_MB)); // configure container resources conf.setContainerDiskRequested(