"old value = " + oldMaxTaskAttempts + ")");
}
}
// Set the job properties, check them, and submit the job
ImmutableClassesGiraphConfiguration conf =
new ImmutableClassesGiraphConfiguration(giraphConfiguration);
checkLocalJobRunnerConfiguration(conf);
int tryCount = 0;
GiraphJobRetryChecker retryChecker = conf.getJobRetryChecker();
while (true) {
JobProgressTrackerService jobProgressTrackerService =
JobProgressTrackerService.createJobProgressServer(conf);
tryCount++;
Job submittedJob = new Job(conf, jobName);
if (submittedJob.getJar() == null) {
submittedJob.setJarByClass(getClass());
}
submittedJob.setNumReduceTasks(0);
submittedJob.setMapperClass(GraphMapper.class);
submittedJob.setInputFormatClass(BspInputFormat.class);
submittedJob.setOutputFormatClass(BspOutputFormat.class);
if (jobProgressTrackerService != null) {
jobProgressTrackerService.setJob(submittedJob);
}
GiraphJobObserver jobObserver = conf.getJobObserver();
jobObserver.launchingJob(submittedJob);
submittedJob.submit();
if (LOG.isInfoEnabled()) {
LOG.info("Tracking URL: " + submittedJob.getTrackingURL());
LOG.info(
"Waiting for resources... Job will start only when it gets all " +
(conf.getMinWorkers() + 1) + " mappers");
}
jobObserver.jobRunning(submittedJob);
HaltApplicationUtils.printHaltInfo(submittedJob, conf);
boolean passed = submittedJob.waitForCompletion(verbose);