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;
     }