Fix RAM config in example code (#3006)

apache · Aug 23, 2018 · 7fb0df3 · 7fb0df3
1 parent 5a11b3e
commit 7fb0df3
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git 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
@@ -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
@@ -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(