Path localJarFile = defaultJobConf.getLocalPath(SUBDIR + "/"
+ task.getTaskID() + "/" + "job.jar");
dfs.copyToLocalFile(new Path(task.getJobFile()), localJobFile);
HamaConfiguration conf = new HamaConfiguration();
conf.addResource(localJobFile);
jobConf = new BSPJob(conf, task.getJobID().toString());
Path jarFile = null;
if (jobConf.getJar() != null) {
jarFile = new Path(jobConf.getJar());