code: public CompletableFuture<Acknowledge> start(final JobMasterId newJobMasterId) throws Exception {
  		// make sure we receive RPC and async calls
  		start();
  
  		return callAsyncWithoutFencing(() -> startJobExecution(newJobMasterId), RpcUtils.INF_TIMEOUT);
  	}
docs: Start the rpc service and begin to run the job.
  
  @param newJobMasterId The necessary fencing token to run the job
  @return Future acknowledge if the job could be started. Otherwise the future contains an exception