You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ib...@apache.org on 2022/11/14 09:33:30 UTC
[ignite-3] branch main updated: IGNITE-18126 Fix NPE in RebalanceRaftGroupEventsListener#onLeaderElected() (#1333)
This is an automated email from the ASF dual-hosted git repository.
ibessonov pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
The following commit(s) were added to refs/heads/main by this push:
new 9e64036f47 IGNITE-18126 Fix NPE in RebalanceRaftGroupEventsListener#onLeaderElected() (#1333)
9e64036f47 is described below
commit 9e64036f4709a83f333869f2b2f067dce105a6c5
Author: Roman Puchkovskiy <ro...@gmail.com>
AuthorDate: Mon Nov 14 13:33:23 2022 +0400
IGNITE-18126 Fix NPE in RebalanceRaftGroupEventsListener#onLeaderElected() (#1333)
---
.../table/distributed/raft/RebalanceRaftGroupEventsListener.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/raft/RebalanceRaftGroupEventsListener.java b/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/raft/RebalanceRaftGroupEventsListener.java
index 8bd867ed12..e7f93c4ce9 100644
--- a/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/raft/RebalanceRaftGroupEventsListener.java
+++ b/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/raft/RebalanceRaftGroupEventsListener.java
@@ -181,7 +181,7 @@ public class RebalanceRaftGroupEventsListener implements RaftGroupEventsListener
Entry pendingEntry = metaStorageMgr.get(pendingPartAssignmentsKey(partId)).get();
- if (!pendingEntry.empty()) {
+ if (pendingEntry.value() != null) {
Set<ClusterNode> pendingNodes = ByteUtils.fromBytes(pendingEntry.value());
LOG.info("New leader elected. Going to reconfigure peers [group={}, partition={}, table={}, peers={}]",