IGNITE-27118 Add new event to listen to

chesnokoff · chesnokoff · commit 413e33e7a723 · 2025-11-24T12:53:59.000+03:00
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/rollingupgrade/RollingUpgradeProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/rollingupgrade/RollingUpgradeProcessor.java
@@ -44,6 +44,7 @@
 import org.jetbrains.annotations.Nullable;
 
 import static org.apache.ignite.events.EventType.EVT_NODE_FAILED;
+import static org.apache.ignite.events.EventType.EVT_NODE_JOINED;
 import static org.apache.ignite.events.EventType.EVT_NODE_LEFT;
 import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_BUILD_VER;
 import static org.apache.ignite.internal.processors.metastorage.DistributedMetaStorage.IGNITE_INTERNAL_KEY_PREFIX;
@@ -103,7 +104,7 @@ public RollingUpgradeProcessor(GridKernalContext ctx) {
                         RollingUpgradeProcessor.this.lastJoiningNode = null;
                 }
             }
-        }, EVT_NODE_FAILED, EVT_NODE_LEFT);
+        }, EVT_NODE_JOINED, EVT_NODE_FAILED, EVT_NODE_LEFT);
 
         ctx.internalSubscriptionProcessor().registerDistributedMetastorageListener(new DistributedMetastorageLifecycleListener() {
             @Override public void onReadyForWrite(DistributedMetaStorage metastorage) {

Original file line number	Diff line number	Diff line change
`@@ -44,6 +44,7 @@`
`44`	`44`	`import org.jetbrains.annotations.Nullable;`
`45`	`45`
`46`	`46`	`import static org.apache.ignite.events.EventType.EVT_NODE_FAILED;`
	`47`	`+import static org.apache.ignite.events.EventType.EVT_NODE_JOINED;`
`47`	`48`	`import static org.apache.ignite.events.EventType.EVT_NODE_LEFT;`
`48`	`49`	`import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_BUILD_VER;`
`49`	`50`	`import static org.apache.ignite.internal.processors.metastorage.DistributedMetaStorage.IGNITE_INTERNAL_KEY_PREFIX;`
`@@ -103,7 +104,7 @@ public RollingUpgradeProcessor(GridKernalContext ctx) {`
`103`	`104`	`RollingUpgradeProcessor.this.lastJoiningNode = null;`
`104`	`105`	`}`
`105`	`106`	`}`
`106`		`- }, EVT_NODE_FAILED, EVT_NODE_LEFT);`
	`107`	`+ }, EVT_NODE_JOINED, EVT_NODE_FAILED, EVT_NODE_LEFT);`
`107`	`108`
`108`	`109`	`ctx.internalSubscriptionProcessor().registerDistributedMetastorageListener(new DistributedMetastorageLifecycleListener() {`
`109`	`110`	`@Override public void onReadyForWrite(DistributedMetaStorage metastorage) {`