flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcService.java
// this method does not mutate state and is thus thread-safe
this method does not mutate state and is thus thread-safe
this method does not mutate state and is thus thread - safe
@Override
	public <C extends RpcGateway> CompletableFuture<C> connect(
			final String address,
			final Class<C> clazz) {
		return connectInternal(
			address,
			clazz,
			(ActorRef actorRef) -> {
				Tuple2<String, String> addressHostname = extractAddressHostname(actorRef);
				return new AkkaInvocationHandler(
					addressHostname.f0,
					addressHostname.f1,
					actorRef,
					timeout,
					maximumFramesize,
					null,
					null);
			});
	}
@ Override public < C extends RpcGateway > CompletableFuture < C > connect ( final String address , final Class < C > clazz ) { return connectInternal ( address , clazz , ( ActorRef actorRef ) -> { Tuple2 < String , String > addressHostname = extractAddressHostname ( actorRef ) ; return new AkkaInvocationHandler ( addressHostname . f0 , addressHostname . f1 , actorRef , timeout , maximumFramesize , null , null ) ; } ) ; }
this method does not mutate state and is thus thread-safe
this method does not mutate state and is thus thread - safe