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

===================================================================
--- src/contrib/mesos/src/java/org/apache/hadoop/mapred/FrameworkScheduler.java	(revision 0)
+++ src/contrib/mesos/src/java/org/apache/hadoop/mapred/FrameworkScheduler.java	(revision 0)
@@ -0,0 +1,776 @@
+package org.apache.hadoop.mapred;
+
+import java.io.File;

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