flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcActor.java
/**
	 * Handle asynchronous {@link Callable}. This method simply executes the given {@link Callable}
	 * in the context of the actor thread.
	 *
	 * @param callAsync Call async message
	 */
Handle asynchronous  Callable. This method simply executes the given  Callable
in the context of the actor thread.

@param callAsync Call async message
Handle asynchronous Callable . This method simply executes the given Callable in the context of the actor thread . @param callAsync Call async message
private void handleCallAsync(CallAsync callAsync) {
		if (callAsync.getCallable() == null) {
			final String result = "Received a " + callAsync.getClass().getName() + " message with an empty " +
				"callable field. This indicates that this message has been serialized " +
				"prior to sending the message. The " + callAsync.getClass().getName() +
				" is only supported with local communication.";
			log.warn(result);
			getSender().tell(new Status.Failure(new AkkaRpcException(result)), getSelf());
		} else {
			try {
				Object result = callAsync.getCallable().call();
				getSender().tell(new Status.Success(result), getSelf());
			} catch (Throwable e) {
				getSender().tell(new Status.Failure(e), getSelf());
			}
		}
	}
private void handleCallAsync ( CallAsync callAsync ) { if ( callAsync . getCallable ( ) == null ) { final String result = "Received a " + callAsync . getClass ( ) . getName ( ) + " message with an empty " + "callable field. This indicates that this message has been serialized " + "prior to sending the message. The " + callAsync . getClass ( ) . getName ( ) + " is only supported with local communication." ; log . warn ( result ) ; getSender ( ) . tell ( new Status . Failure ( new AkkaRpcException ( result ) ) , getSelf ( ) ) ; } else { try { Object result = callAsync . getCallable ( ) . call ( ) ; getSender ( ) . tell ( new Status . Success ( result ) , getSelf ( ) ) ; } catch ( Throwable e ) { getSender ( ) . tell ( new Status . Failure ( e ) , getSelf ( ) ) ; } } }
Handle asynchronous {@link Callable}.
Handle asynchronous { @link Callable } .