This is an automated email from the ASF dual-hosted git repository. apolovtsev 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 f7c25c937d IGNITE-18275 Remove obsolete TODOs (#3685) f7c25c937d is described below commit f7c25c937de44c1c8b89bc8ca32ca479e6dc44fb Author: Alexander Polovtcev <alex.polovt...@gmail.com> AuthorDate: Tue Apr 30 12:10:39 2024 +0300 IGNITE-18275 Remove obsolete TODOs (#3685) --- .../internal/cluster/management/ClusterManagementGroupManager.java | 2 -- 1 file changed, 2 deletions(-) diff --git a/modules/cluster-management/src/main/java/org/apache/ignite/internal/cluster/management/ClusterManagementGroupManager.java b/modules/cluster-management/src/main/java/org/apache/ignite/internal/cluster/management/ClusterManagementGroupManager.java index 8928be067d..6efd1feea7 100644 --- a/modules/cluster-management/src/main/java/org/apache/ignite/internal/cluster/management/ClusterManagementGroupManager.java +++ b/modules/cluster-management/src/main/java/org/apache/ignite/internal/cluster/management/ClusterManagementGroupManager.java @@ -362,7 +362,6 @@ public class ClusterManagementGroupManager implements IgniteComponent { LOG.info("CMG leader has been elected, executing onLeaderElected callback"); // The cluster state is broadcast via the messaging service; hence, the future must be completed here on the leader node. - // TODO: This needs to be reworked following the implementation of IGNITE-18275. raftServiceAfterJoin().thenAccept(service -> inBusyLock(busyLock, () -> { service.readClusterState() .thenAccept(state -> initialClusterConfigurationFuture.complete(state.initialClusterConfiguration())); @@ -378,7 +377,6 @@ public class ClusterManagementGroupManager implements IgniteComponent { // Send the ClusterStateMessage to all members of the physical topology. We do not wait for the send operation // because being unable to send ClusterState messages should not fail the CMG service startup. - // TODO: IGNITE-18275 - use RAFT replication instead of message sending ClusterNode thisNode = topologyService.localMember(); Collection<ClusterNode> otherNodes = topologyService.allMembers().stream()