[
https://issues.apache.org/jira/browse/FLINK-4451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433096#comment-15433096
]
ASF GitHub Bot commented on FLINK-4451:
---------------------------------------
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2405
[FLINK-4451] [rpc] Throw RpcConnectionException when rpc endpoint is not
reachable
This PR introduces a RpcConnectionException which is thrown if the rpc
endpoint
is not reachable when calling RpcService.connect.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/tillrohrmann/flink fixRpcConnect
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/2405.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #2405
----
commit 7b9936dabbf616de2f51939c44fa30cc8c47c1ba
Author: Till Rohrmann <[email protected]>
Date: 2016-08-23T15:59:54Z
[FLINK-4451] [rpc] Throw RpcConnectionException when rpc endpoint is not
reachable
This PR introduces a RpcConnectionException which is thrown if the rpc
endpoint
is not reachable when calling RpcService.connect.
----
> Throw exception when remote connection cannot be resolved
> ---------------------------------------------------------
>
> Key: FLINK-4451
> URL: https://issues.apache.org/jira/browse/FLINK-4451
> Project: Flink
> Issue Type: Sub-task
> Components: Distributed Coordination
> Reporter: Till Rohrmann
> Assignee: Till Rohrmann
>
> 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}}.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
