svn commit: r1132085 - /incubator/mesos/trunk/frameworks/mpi/nmpiexec.py

[be...@apache.org]

Author: benh
Date: Sun Jun  5 08:39:20 2011
New Revision: 1132085

URL: http://svn.apache.org/viewvc?rev=1132085&view=rev
Log:
MPI framework fixes

Modified:
    incubator/mesos/trunk/frameworks/mpi/nmpiexec.py

Modified: incubator/mesos/trunk/frameworks/mpi/nmpiexec.py
URL: http://svn.apache.org/viewvc/incubator/mesos/trunk/frameworks/mpi/nmpiexec.py?rev=1132085&r1=1132084&r2=1132085&view=diff
==============================================================================
--- incubator/mesos/trunk/frameworks/mpi/nmpiexec.py (original)
+++ incubator/mesos/trunk/frameworks/mpi/nmpiexec.py Sun Jun  5 08:39:20 2011
@@ -36,7 +36,7 @@ class MyScheduler(mesos.Scheduler):
     self.tasksLaunched = 0
     self.tasksFinished = 0
 
-  def getFrameorkName(self, driver):
+  def getFrameworkName(self, driver):
     return "Mesos MPI Framework"
 
   def getExecutorInfo(self, driver):
@@ -48,7 +48,7 @@ class MyScheduler(mesos.Scheduler):
     print "Mesos MPI scheduler and mpd running at "+self.ip+":"+self.port
 
   def resourceOffer(self, driver, oid, offers):
-    print "Got offer %d" % oid
+    print "Got offer %s" % oid
     tasks = []
     if self.tasksLaunched == TOTAL_TASKS:
       print "Rejecting permanently because we have already started"
@@ -117,7 +117,7 @@ if __name__ == "__main__":
                     help="number of cpus per slot (default 1)",
                     dest="cpus", type="int", default=CPUS)
   parser.add_option("-m","--mem",
-                    help="number of bytes of memory per slot (default 1GB)",
+                    help="number of MB of memory per slot (default 1GB)",
                     dest="mem", type="int", default=MEM)
 
   (options,args)=parser.parse_args()