flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java
/**
	 * Updates the associated configuration with the given command line options.
	 *
	 * @param options Command line options
	 */
Updates the associated configuration with the given command line options.
@param options Command line options
Updates the associated configuration with the given command line options . @param options Command line options
protected ClusterClient retrieveClient(CommandLineOptions options) {
		CustomCommandLine customCLI = getActiveCustomCommandLine(options.getCommandLine());
		try {
			ClusterClient client = customCLI.retrieveCluster(options.getCommandLine(), config, configurationDirectory);
			logAndSysout("Using address " + client.getJobManagerAddress() + " to connect to JobManager.");
			return client;
		} catch (Exception e) {
			LOG.error("Couldn't retrieve {} cluster.", customCLI.getId(), e);
			throw new IllegalConfigurationException("Couldn't retrieve client for cluster", e);
		}
	}
protected ClusterClient retrieveClient ( CommandLineOptions options ) { CustomCommandLine customCLI = getActiveCustomCommandLine ( options . getCommandLine ( ) ) ; try { ClusterClient client = customCLI . retrieveCluster ( options . getCommandLine ( ) , config , configurationDirectory ) ; logAndSysout ( "Using address " + client . getJobManagerAddress ( ) + " to connect to JobManager." ) ; return client ; } catch ( Exception e ) { LOG . error ( "Couldn't retrieve {} cluster." , customCLI . getId ( ) , e ) ; throw new IllegalConfigurationException ( "Couldn't retrieve client for cluster" , e ) ; } }
Updates the associated configuration with the given command line options.
Updates the associated configuration with the given command line options .