Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2381
Hi @wenlong88,
1. I'm actually not so sure whether `RpcGateway.getAddress` method is
something framework specific. For any `RpcService` implementation you need some
kind of address to connect to a `RpcEndpoint`. The `RpcService` has the method
`connect` which requires exactly this information to open a connection. Thus, I
think that every `RpcGateway` should be able to tell to which `RpcEndpoint` it
is currently connected. So for example, there is currently also no way to open
another `RpcGateway` to the same `RpcEndpoint` given a `RpcGateway`. What do
you think?
2. You're right, the current implementation has the same problem and should
be fixed either way.
---
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 [email protected] or file a JIRA ticket
with INFRA.
---
