code: @Override
    protected RunningJob createRunningJob(JobID jobId, TaskInProgress tip)
        throws IOException {
      CoronaSessionInfo info = (CoronaSessionInfo)(tip.getExtensible());
      // JobClient will be set by JobTrackerReporter thread later
      RunningJob rJob = new RunningJob(jobId, null, info);
      JobTrackerReporter reporter = new JobTrackerReporter(rJob,
          info.getJobTrackerAddr(), info.getSecondaryTracker(),
          info.getSessionHandle());
      reporter.setName("JobTrackerReporter for " + jobId);
      // Start the heartbeat to the jobtracker
      reporter.start();
      jobTrackerReporters.put(jobId, reporter);
      return rJob;
    }
docs: Override this method to create the proper jobClient and the thread that
  sends jobTracker heartbeat.