 +import mesos.Scheduler;
 +import mesos.SchedulerDriver;
 +import mesos.SlaveOffer;
-+import mesos.SlaveOfferVector;
-+import mesos.StringMap;
 +import mesos.TaskDescription;
-+import mesos.TaskDescriptionVector;
 +import mesos.TaskState;
 +
 +public class FrameworkScheduler extends Scheduler {

+    
+    // Create a task description to pass back to Mesos
+    String name = "task " + mesosId + " (" + taskType + ")";
+    StringMap params = new StringMap();
+    params.set("cpus", "" + cpusPerTask);
+    params.set("mem", "" + memPerTask);
+    return new TaskDescription(mesosId, slaveId, name, params, new byte[0]);
+  }
+

+          }
+        }
+        
+        Map<String, String> params = new HashMap<String, String>();
+        params.put("timeout", "1");
+        d.replyToOffer(oid, tasks, params);
+      }
+    } catch(Exception e) {
