Export - CSV (All fields)
Export - CSV (Current fields)
FLINK-9365
Add version information to remote rpc messages
Add support for scheduleRunAsync for FencedRpcEndpoints
Add UnfencedMainThreadExecutor to FencedRpcEndpoint
Make AkkaRpcService#stopService non-blocking
Allow RpcEndpoint#postStop to complete asynchronously
Change termination future type of RpcEndpoint to Void
Shut down AkkaRpcActors with PoisonPill
Simplify termination future completion
Complete termination future after actor has been stopped.
Let RpcEndpoint directly implement RpcGateways
Add callback for proper RpcEndpoint shut down
Add getPort method to RpcService
Support fencing tokens to filter out outdated messages
Remove TestingSerialRpcService
Create SerialMainThreadValidatorUtil to support TestingSerialRpcService
Allow to specify endpoint names
Let RpcService.scheduleRunnable return ScheduledFuture
Let the RPCService provide a ScheduledExecutorService
Properly unpack thrown exceptions in RPC methods
Remove stashing from AkkaRpcActor
Let RpcEndpoint.start/shutDown throw exceptions
RpcCompletenessTest: Add support for type arguments and subclasses
Add wait for termination function to RpcEndpoints
Add getAddress method to RpcService
Allow RpcService to execute Callables in the RpcService executor
Port existing code to use Flink's future abstraction
Check that the RpcEndpoint supports the specified RpcGateway
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
Mark runAsync and scheduleAsync methods protected
Throw exception when remote connection cannot be resolved
Add support in RpcCompletenessTest for inheritance of RpcGateway and RpcEndpoint
Add a testing RPC service
Remove restriction on RpcService.getAddress
RPC proxy classloading should use Flink class' classloader
Make RPC Service Thread Safe
Add throws clause verification to RpcCompletenessTest
Add as way to assert that code runs in the RpcEndpoint's Main Thread
Add a "scheduleRunAsync()" feature to the RpcEndpoint
Check parameters for serializability before sending a remote RpcInvocation message
Buffer rpc calls until RpcEndpoint is properly started
Eagerly initialize RrcProtocol members
Auto generate message sender classes via Java Proxies
Introduce Flink's own future abstraction