Repository: incubator-reef Updated Branches: refs/heads/branch-0.11.0-incubating-maven b4e0d4ce3 -> d0e4a4811
pick up the change from REEF-293, PR 167 for Null Point Exception issues on Mesos Project: http://git-wip-us.apache.org/repos/asf/incubator-reef/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-reef/commit/f6aa4b2e Tree: http://git-wip-us.apache.org/repos/asf/incubator-reef/tree/f6aa4b2e Diff: http://git-wip-us.apache.org/repos/asf/incubator-reef/diff/f6aa4b2e Branch: refs/heads/branch-0.11.0-incubating-maven Commit: f6aa4b2ec86edcf6b3989f0bc0f2ac480056f2de Parents: b4e0d4c Author: Julia Wang <[email protected]> Authored: Thu Apr 30 18:29:58 2015 -0700 Committer: Julia Wang <[email protected]> Committed: Thu Apr 30 18:29:58 2015 -0700 ---------------------------------------------------------------------- .../java/org/apache/reef/runtime/mesos/driver/REEFScheduler.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/f6aa4b2e/lang/java/reef-runtime-mesos/src/main/java/org/apache/reef/runtime/mesos/driver/REEFScheduler.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-runtime-mesos/src/main/java/org/apache/reef/runtime/mesos/driver/REEFScheduler.java b/lang/java/reef-runtime-mesos/src/main/java/org/apache/reef/runtime/mesos/driver/REEFScheduler.java index ba11aae..1b94182 100644 --- a/lang/java/reef-runtime-mesos/src/main/java/org/apache/reef/runtime/mesos/driver/REEFScheduler.java +++ b/lang/java/reef-runtime-mesos/src/main/java/org/apache/reef/runtime/mesos/driver/REEFScheduler.java @@ -384,6 +384,7 @@ final class REEFScheduler implements Scheduler { .setIdentifier(taskStatus.getTaskId().getValue()) .setNodeId(taskStatus.getSlaveId().getValue()) .setResourceMemory(resourceRequestProto.getMemorySize().get()) + .setVirtualCores(resourceRequestProto.getVirtualCores().get()) .build(); reefEventHandlers.onResourceAllocation(alloc);
