Repository: incubator-reef Updated Branches: refs/heads/master fae8298cc -> 234a91a1c
[REEF-706] Fix DataLoadingREEF example Create a DataRequest and add to dataLoadConfiguration correctly. JIRA: [REEF-706](https://issues.apache.org/jira/browse/REEF-706) Pull Request: This closes #455 Project: http://git-wip-us.apache.org/repos/asf/incubator-reef/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-reef/commit/234a91a1 Tree: http://git-wip-us.apache.org/repos/asf/incubator-reef/tree/234a91a1 Diff: http://git-wip-us.apache.org/repos/asf/incubator-reef/diff/234a91a1 Branch: refs/heads/master Commit: 234a91a1c45fbda7a5e7b8407b15f9cf1e090fd9 Parents: fae8298 Author: Dongjoon Hyun <[email protected]> Authored: Tue Sep 1 11:51:34 2015 +0900 Committer: Markus Weimer <[email protected]> Committed: Tue Sep 1 09:52:14 2015 -0700 ---------------------------------------------------------------------- .../org/apache/reef/examples/data/loading/DataLoadingREEF.java | 6 ++++++ 1 file changed, 6 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/234a91a1/lang/java/reef-examples/src/main/java/org/apache/reef/examples/data/loading/DataLoadingREEF.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-examples/src/main/java/org/apache/reef/examples/data/loading/DataLoadingREEF.java b/lang/java/reef-examples/src/main/java/org/apache/reef/examples/data/loading/DataLoadingREEF.java index 4c15957..e054688 100644 --- a/lang/java/reef-examples/src/main/java/org/apache/reef/examples/data/loading/DataLoadingREEF.java +++ b/lang/java/reef-examples/src/main/java/org/apache/reef/examples/data/loading/DataLoadingREEF.java @@ -94,11 +94,17 @@ public final class DataLoadingREEF { .setNumberOfCores(1) .build(); + final EvaluatorRequest dataRequest = EvaluatorRequest.newBuilder() + .setMemory(512) + .setNumberOfCores(1) + .build(); + final Configuration dataLoadConfiguration = new DataLoadingRequestBuilder() .setInputFormatClass(TextInputFormat.class) .setInputPath(inputDir) .setNumberOfDesiredSplits(NUM_SPLITS) .addComputeRequest(computeRequest) + .addDataRequest(dataRequest) .setDriverConfigurationModule(DriverConfiguration.CONF .set(DriverConfiguration.GLOBAL_LIBRARIES, EnvironmentUtils.getClassLocation(LineCounter.class)) .set(DriverConfiguration.ON_CONTEXT_ACTIVE, LineCounter.ContextActiveHandler.class)
