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 <[email protected]>
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()
