public void startJob ( String targetCluster ) throws ExecutionException { getConnection ( targetCluster ) . setJobInProgress ( true ) ; logger . info ( "a new job has been started in cluster [" + targetCluster + "]" ) ; }
This method start a work for a connections .