Updated Branches: refs/heads/master 2133ba99a -> 503a98fad
Added checkpoint parameter to JobTracker. Now it's possible to set checkpoint=true for the Hadoop framework by specifying mapred.mesos.checkpoint=true in the Hadoop config. Review: https://reviews.apache.org/r/13091 Project: http://git-wip-us.apache.org/repos/asf/mesos/repo Commit: http://git-wip-us.apache.org/repos/asf/mesos/commit/503a98fa Tree: http://git-wip-us.apache.org/repos/asf/mesos/tree/503a98fa Diff: http://git-wip-us.apache.org/repos/asf/mesos/diff/503a98fa Branch: refs/heads/master Commit: 503a98fad91d02776ac608da2f95d504ed4cc665 Parents: 2133ba9 Author: Brenden Matthews <[email protected]> Authored: Tue Jul 30 16:15:23 2013 -0700 Committer: Brenden Matthews <[email protected]> Committed: Thu Aug 1 17:17:25 2013 -0700 ---------------------------------------------------------------------- hadoop/mesos/src/java/org/apache/hadoop/mapred/MesosScheduler.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/mesos/blob/503a98fa/hadoop/mesos/src/java/org/apache/hadoop/mapred/MesosScheduler.java ---------------------------------------------------------------------- diff --git a/hadoop/mesos/src/java/org/apache/hadoop/mapred/MesosScheduler.java b/hadoop/mesos/src/java/org/apache/hadoop/mapred/MesosScheduler.java index 98eacf3..1923d49 100644 --- a/hadoop/mesos/src/java/org/apache/hadoop/mapred/MesosScheduler.java +++ b/hadoop/mesos/src/java/org/apache/hadoop/mapred/MesosScheduler.java @@ -195,6 +195,7 @@ public class MesosScheduler extends TaskScheduler implements Scheduler { FrameworkInfo frameworkInfo = FrameworkInfo .newBuilder() .setUser("") + .setCheckpoint(conf.getBoolean("mapred.mesos.checkpoint", false)) .setName("Hadoop: (RPC port: " + jobTracker.port + "," + " WebUI port: " + jobTracker.infoPort + ")").build();
