Bulk Operation

FLINK-4346 Add version information to remote rpc messages

FLINK-4346 Add support for scheduleRunAsync for FencedRpcEndpoints

FLINK-4346 Add UnfencedMainThreadExecutor to FencedRpcEndpoint

FLINK-4346 Make AkkaRpcService#stopService non-blocking

FLINK-4346 Allow RpcEndpoint#postStop to complete asynchronously

FLINK-4346 Change termination future type of RpcEndpoint to Void

FLINK-4346 Shut down AkkaRpcActors with PoisonPill

FLINK-4346 Simplify termination future completion

FLINK-4346 Complete termination future after actor has been stopped.

FLINK-4346 Let RpcEndpoint directly implement RpcGateways

FLINK-4346 Add callback for proper RpcEndpoint shut down

FLINK-4346 Add getPort method to RpcService

FLINK-4346 Support fencing tokens to filter out outdated messages

FLINK-4346 Remove TestingSerialRpcService

FLINK-4346 Create SerialMainThreadValidatorUtil to support TestingSerialRpcService

FLINK-4346 Allow to specify endpoint names

FLINK-4346 Let RpcService.scheduleRunnable return ScheduledFuture

FLINK-4346 Let the RPCService provide a ScheduledExecutorService

FLINK-4346 Properly unpack thrown exceptions in RPC methods

FLINK-4346 Remove stashing from AkkaRpcActor

FLINK-4346 Let RpcEndpoint.start/shutDown throw exceptions

FLINK-4346 RpcCompletenessTest: Add support for type arguments and subclasses

FLINK-4346 Add wait for termination function to RpcEndpoints

FLINK-4346 Add getAddress method to RpcService

FLINK-4346 Allow RpcService to execute Callables in the RpcService executor

FLINK-4346 Port existing code to use Flink's future abstraction

FLINK-4346 Check that the RpcEndpoint supports the specified RpcGateway

FLINK-4346 when call connect method in AkkaRpcService using same address and same rpc gateway class, the returned gateways are equal with respect to equals and hashCode

FLINK-4346 Mark runAsync and scheduleAsync methods protected

FLINK-4346 Throw exception when remote connection cannot be resolved

FLINK-4346 Add support in RpcCompletenessTest for inheritance of RpcGateway and RpcEndpoint

FLINK-4346 Add a testing RPC service

FLINK-4346 Remove restriction on RpcService.getAddress

FLINK-4346 RPC proxy classloading should use Flink class' classloader

FLINK-4346 Make RPC Service Thread Safe

FLINK-4346 Add throws clause verification to RpcCompletenessTest

FLINK-4346 Add as way to assert that code runs in the RpcEndpoint's Main Thread

FLINK-4346 Add a "scheduleRunAsync()" feature to the RpcEndpoint

FLINK-4346 Check parameters for serializability before sending a remote RpcInvocation message

FLINK-4346 Buffer rpc calls until RpcEndpoint is properly started

FLINK-4346 Eagerly initialize RrcProtocol members

FLINK-4346 Auto generate message sender classes via Java Proxies

FLINK-4346 Introduce Flink's own future abstraction