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);