(ignite-3) branch main updated: IGNITE-26144 Do not fail node on node stop in PlacementDriverManager (#6462)

[rpuch]

This is an automated email from the ASF dual-hosted git repository.

rpuch 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 14ab3b77c8a IGNITE-26144 Do not fail node on node stop in 
PlacementDriverManager (#6462)
14ab3b77c8a is described below

commit 14ab3b77c8a0de60647233fd0e4a80145cc2ffa2
Author: Roman Puchkovskiy <roman.puchkovs...@gmail.com>
AuthorDate: Fri Aug 22 10:10:20 2025 +0400

    IGNITE-26144 Do not fail node on node stop in PlacementDriverManager (#6462)
---
 .../ignite/internal/placementdriver/PlacementDriverManager.java      | 5 ++++-
 .../ignite/internal/disaster/system/ItCmgDisasterRecoveryTest.java   | 2 +-
 2 files changed, 5 insertions(+), 2 deletions(-)

diff --git 
a/modules/placement-driver/src/main/java/org/apache/ignite/internal/placementdriver/PlacementDriverManager.java
 
b/modules/placement-driver/src/main/java/org/apache/ignite/internal/placementdriver/PlacementDriverManager.java
index b5dbb661c5c..b9926eb8dd5 100644
--- 
a/modules/placement-driver/src/main/java/org/apache/ignite/internal/placementdriver/PlacementDriverManager.java
+++ 
b/modules/placement-driver/src/main/java/org/apache/ignite/internal/placementdriver/PlacementDriverManager.java
@@ -19,6 +19,7 @@ package org.apache.ignite.internal.placementdriver;
 
 import static java.util.concurrent.CompletableFuture.failedFuture;
 import static 
org.apache.ignite.internal.util.CompletableFutures.nullCompletedFuture;
+import static org.apache.ignite.internal.util.ExceptionUtils.hasCause;
 import static org.apache.ignite.internal.util.IgniteUtils.inBusyLock;
 
 import java.util.List;
@@ -204,7 +205,9 @@ public class PlacementDriverManager implements 
IgniteComponent {
                         if (ex == null) {
                             raftClientFuture.complete(client);
                         } else {
-                            failureProcessor.process(new FailureContext(ex, 
"Placement driver initialization exception"));
+                            if (!hasCause(ex, NodeStoppingException.class)) {
+                                failureProcessor.process(new 
FailureContext(ex, "Placement driver initialization exception"));
+                            }
 
                             raftClientFuture.completeExceptionally(ex);
                         }
diff --git 
a/modules/system-disaster-recovery/src/integrationTest/java/org/apache/ignite/internal/disaster/system/ItCmgDisasterRecoveryTest.java
 
b/modules/system-disaster-recovery/src/integrationTest/java/org/apache/ignite/internal/disaster/system/ItCmgDisasterRecoveryTest.java
index 3fa4b0f13cc..307e9849ab3 100644
--- 
a/modules/system-disaster-recovery/src/integrationTest/java/org/apache/ignite/internal/disaster/system/ItCmgDisasterRecoveryTest.java
+++ 
b/modules/system-disaster-recovery/src/integrationTest/java/org/apache/ignite/internal/disaster/system/ItCmgDisasterRecoveryTest.java
@@ -343,7 +343,7 @@ class ItCmgDisasterRecoveryTest extends 
ItSystemGroupDisasterRecoveryTest {
     }
 
     @Test
-    @Disabled("https://issues.apache.org/jira/browse/IGNITE-26144";)
+    @Disabled("https://issues.apache.org/jira/browse/IGNITE-26262";)
     void repairWorksWhenCmgMajorityIsOnline() throws Exception {
         startAndInitCluster(3, new int[]{0, 1, 2}, new int[]{1});
         waitTillClusterStateIsSavedToVaultOnConductor(1);