private synchronized void requestEvaluators ( ) { assert this . state == State . INIT ; LOG . log ( Level . INFO , "Schedule on {0} Evaluators." , this . numEvaluators ) ; this . evaluatorRequestor . newRequest ( ) . setMemory ( 128 ) . setNumberOfCores ( 1 ) . setNumber ( this . numEvaluators ) . submit ( ) ; this . state = State . WAIT_EVALUATORS ; this . expectCount = this . numEvaluators ; }
Request the evaluators .