flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobGraph.java
/**
	 * Uploads the previously added user JAR files to the job manager through
	 * the job manager's BLOB server. The BLOB servers' address is given as a
	 * parameter. This function issues a blocking call.
	 *
	 * @param blobServerAddress of the blob server to upload the jars to
	 * @param blobClientConfig the blob client configuration
	 * @throws IOException Thrown, if the file upload to the JobManager failed.
	 */
Uploads the previously added user JAR files to the job manager through
the job manager's BLOB server. The BLOB servers' address is given as a
parameter. This function issues a blocking call.

@param blobServerAddress of the blob server to upload the jars to
@param blobClientConfig the blob client configuration
@throws IOException Thrown, if the file upload to the JobManager failed.
Uploads the previously added user JAR files to the job manager through the job manager ' s BLOB server . The BLOB servers ' address is given as a parameter . This function issues a blocking call . @param blobServerAddress of the blob server to upload the jars to @param blobClientConfig the blob client configuration @throws IOException Thrown if the file upload to the JobManager failed .
public void uploadUserJars(
			InetSocketAddress blobServerAddress,
			Configuration blobClientConfig) throws IOException {
		if (!userJars.isEmpty()) {
			List<PermanentBlobKey> blobKeys = BlobClient.uploadJarFiles(
				blobServerAddress, blobClientConfig, jobID, userJars);
			for (PermanentBlobKey blobKey : blobKeys) {
				if (!userJarBlobKeys.contains(blobKey)) {
					userJarBlobKeys.add(blobKey);
				}
			}
		}
	}
public void uploadUserJars ( InetSocketAddress blobServerAddress , Configuration blobClientConfig ) throws IOException { if ( ! userJars . isEmpty ( ) ) { List < PermanentBlobKey > blobKeys = BlobClient . uploadJarFiles ( blobServerAddress , blobClientConfig , jobID , userJars ) ; for ( PermanentBlobKey blobKey : blobKeys ) { if ( ! userJarBlobKeys . contains ( blobKey ) ) { userJarBlobKeys . add ( blobKey ) ; } } } }
Uploads the previously added user JAR files to the job manager through
 the job manager's BLOB server.
Uploads the previously added user JAR files to the job manager through the job manager ' s BLOB server .