code: public void submit() throws IOException, InterruptedException,
                                ClassNotFoundException {
      ensureState(JobState.DEFINE);
      setUseNewAPI();
      info = jobClient.submitJobInternal(conf);
      state = JobState.RUNNING;
     }
docs: Submit the job to the cluster and return immediately.
  @throws IOException