private void submitJobToHelix ( String jobName , String jobId , JobConfig . Builder jobConfigBuilder ) throws Exception { TaskDriver taskDriver = new TaskDriver ( this . planningJobHelixManager ) ; HelixUtils . submitJobToWorkFlow ( jobConfigBuilder , jobName , jobId , taskDriver , this . planningJobHelixManager , this . workFlowExpiryTimeSeconds ) ; this . jobSubmitted = true ; }
Submit a planning job to helix so that it can launched from a remote node .