You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by am...@apache.org on 2021/09/13 08:57:43 UTC
[ignite-3] 01/01: Fix incorrect set item removal.
This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a commit to branch ignite-15439
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
commit 46453f6c8bb84ee8a4b52647237075e4d257e194
Author: Andrew Mashenkov <an...@gmail.com>
AuthorDate: Mon Sep 13 11:57:32 2021 +0300
Fix incorrect set item removal.
---
.../org/apache/ignite/raft/jraft/rpc/impl/AbstractClientService.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/modules/raft/src/main/java/org/apache/ignite/raft/jraft/rpc/impl/AbstractClientService.java b/modules/raft/src/main/java/org/apache/ignite/raft/jraft/rpc/impl/AbstractClientService.java
index 8cb5fe9..b0c0240 100644
--- a/modules/raft/src/main/java/org/apache/ignite/raft/jraft/rpc/impl/AbstractClientService.java
+++ b/modules/raft/src/main/java/org/apache/ignite/raft/jraft/rpc/impl/AbstractClientService.java
@@ -76,7 +76,7 @@ public abstract class AbstractClientService implements ClientService, TopologyEv
}
@Override public void onDisappeared(ClusterNode member) {
- readyAddresses.remove(member.address());
+ readyAddresses.remove(member.address().toString());
}
protected void configRpcClient(final RpcClient rpcClient) {
@@ -91,7 +91,7 @@ public abstract class AbstractClientService implements ClientService, TopologyEv
// TODO asch should the client be created lazily? A client doesn't make sence without a server IGNITE-14832
this.rpcClient.init(null);
- this.rpcExecutor = ((RpcOptions)rpcOptions).getClientExecutor();
+ this.rpcExecutor = rpcOptions.getClientExecutor();
return true;
}