Github user wenlong88 commented on the issue:
https://github.com/apache/flink/pull/2381
Coming back to the initial motivation of this PR, It is because that I
tried to get the address from the RpcService, and the RpcService provides a api
`getAddress(RpcGateway gateway)` but can noly provide the address of endpoint
created on it only.
Another solution just for discuss:
1. change function prototype to `getAddress(RpcEndpoint endpoint)`
2. the AkkaRpcService can adapt this change easily, since we can get
actorRef from RpcEndpoint, and do what is done now. Besides, AkkaRpcService
need to check whether the actorRef is in the cached actors and raise a
exception if not.
In this way, we cannot get address from gateway, but it also make sense
since the endpoint is server , which must have a address to visit, and the
gateway is a client, providing an address is an optional.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
