[FLINK-4451] Throw exception when remote connection cannot be resolved

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Component/s: Runtime / Coordination
• Assignee: Till Rohrmann
• Reporter: Till Rohrmann
• Created: 23/Aug/16 14:21
• Updated: 05/Sep/16 09:16
• Resolved: 24/Aug/16 15:07

Description

The RpcService implementation should throw an exception (returned in the future) if RpcService.connect(address, type) cannot connect to the remote RpcEndpoint.

At the moment the AkkaRpcService does not check that the IdentifyActor message contains a valid ActorRef and throws due to that a NullPointerException.

Issue Links

• links to: GitHub Pull Request #2405