Skip to content
This repository has been archived by the owner on Mar 3, 2023. It is now read-only.

Fix RAM config in example code #3006

Merged
merged 1 commit into from Aug 23, 2018
Merged

Fix RAM config in example code #3006

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
2 changes: 1 addition & 1 deletion examples/src/java/org/apache/heron/examples/api/ExampleResources.java
View file
Open in desktop
Expand Up @@ -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);
Expand Down
4 changes: 2 additions & 2 deletions examples/src/java/org/apache/heron/examples/api/StatefulWordCountTopology.java
View file
Open in desktop
Expand Up @@ -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(
Expand Down
4 changes: 2 additions & 2 deletions examples/src/java/org/apache/heron/examples/api/WordCountTopology.java
View file
Open in desktop
Expand Up @@ -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(
Expand Down