You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@reef.apache.org by jo...@apache.org on 2015/04/30 05:52:16 UTC

incubator-reef git commit: [REEF-293] reef-tests NullPointerException on Mesos

Repository: incubator-reef
Updated Branches:
  refs/heads/master 2d37964c4 -> 19fdfcc65


[REEF-293] reef-tests NullPointerException on Mesos

This PR adds virtual cores to avoid the NullPointerException.

JIRA:
  [REEF-293](https://issues.apache.org/jira/browse/REEF-293)

Pull Request:
  Closes #167


Project: http://git-wip-us.apache.org/repos/asf/incubator-reef/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-reef/commit/19fdfcc6
Tree: http://git-wip-us.apache.org/repos/asf/incubator-reef/tree/19fdfcc6
Diff: http://git-wip-us.apache.org/repos/asf/incubator-reef/diff/19fdfcc6

Branch: refs/heads/master
Commit: 19fdfcc65f4dc1c86e0a3f20928a93f38380e67e
Parents: 2d37964
Author: Brian Cho <ch...@apache.org>
Authored: Thu Apr 30 11:36:56 2015 +0900
Committer: John Yang <jo...@apache.org>
Committed: Thu Apr 30 11:55:20 2015 +0900

----------------------------------------------------------------------
 .../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/19fdfcc6/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);