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