GitHub user beyond1920 opened a pull request:
https://github.com/apache/flink/pull/2455
[FLINK-4547] [cluster management] Return same object when call connect
method in AkkaRpcService using same address and same rpc gateway class
The pull request is to add equals and hashCode method to
AkkaInvocationHandler class.
Now every time call connect method in AkkaRpcService class using same
address and same rpc gateway class, the return gateway object is totally
different with each other which equals and hashcode are not same.
Maybe itâs reasonable to have the same result (equals return true, and
hashcode is same) when using the same address and same Gateway class.
Main difference are 2 points:
1. Add equals and hashCode method to AkkaInvocationHandler class
2. Add a test for connect method in AkkaRpcService
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/alibaba/flink jira-4547
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/2455.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 #2455
----
commit 8504f1075b4c4c51f37aab2b45b864f885dc76a3
Author: beyond1920 <beyond1...@126.com>
Date: 2016-09-01T07:00:03Z
add equals and hashcode in AkkaInvocationHandler
----
---
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.
---
