flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-runtime/src/main/java/org/apache/flink/runtime/client/JobClient.java
/**
	 * Utility method to retrieve the BlobServer address from the given JobManager gateway.
	 *
	 * @param jobManagerGateway to obtain the BlobServer address from
	 * @param timeout for this operation
	 * @return CompletableFuture containing the BlobServer address
	 */
Utility method to retrieve the BlobServer address from the given JobManager gateway.
@param jobManagerGateway to obtain the BlobServer address from
@param timeout for this operation
@return CompletableFuture containing the BlobServer address
Utility method to retrieve the BlobServer address from the given JobManager gateway . @param jobManagerGateway to obtain the BlobServer address from @param timeout for this operation @return CompletableFuture containing the BlobServer address
public static CompletableFuture<InetSocketAddress> retrieveBlobServerAddress(
			JobManagerGateway jobManagerGateway,
			Time timeout) {
		CompletableFuture<Integer> futureBlobPort = jobManagerGateway.requestBlobServerPort(timeout);
		final String jmHostname = jobManagerGateway.getHostname();
		return futureBlobPort.thenApply(
			(Integer blobPort) -> new InetSocketAddress(jmHostname, blobPort));
	}
public static CompletableFuture < InetSocketAddress > retrieveBlobServerAddress ( JobManagerGateway jobManagerGateway , Time timeout ) { CompletableFuture < Integer > futureBlobPort = jobManagerGateway . requestBlobServerPort ( timeout ) ; final String jmHostname = jobManagerGateway . getHostname ( ) ; return futureBlobPort . thenApply ( ( Integer blobPort ) -> new InetSocketAddress ( jmHostname , blobPort ) ) ; }
Utility method to retrieve the BlobServer address from the given JobManager gateway.
Utility method to retrieve the BlobServer address from the given JobManager gateway .