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 ca4713c34d7 IGNITE-27374 Do not fail node on stop in 
makeIndexAvailableInCatalogWithoutFuture() (#7257)
ca4713c34d7 is described below

commit ca4713c34d7c947a95f93d45ec64f785dafd4c09
Author: Roman Puchkovskiy <[email protected]>
AuthorDate: Wed Dec 17 11:30:56 2025 +0400

    IGNITE-27374 Do not fail node on stop in 
makeIndexAvailableInCatalogWithoutFuture() (#7257)
---
 .../apache/ignite/internal/index/IndexManagementUtils.java  | 13 +++++++------
 1 file changed, 7 insertions(+), 6 deletions(-)

diff --git 
a/modules/index/src/main/java/org/apache/ignite/internal/index/IndexManagementUtils.java
 
b/modules/index/src/main/java/org/apache/ignite/internal/index/IndexManagementUtils.java
index ddcac6151c8..c1d99ad6ca0 100644
--- 
a/modules/index/src/main/java/org/apache/ignite/internal/index/IndexManagementUtils.java
+++ 
b/modules/index/src/main/java/org/apache/ignite/internal/index/IndexManagementUtils.java
@@ -26,7 +26,7 @@ import static 
org.apache.ignite.internal.metastorage.dsl.Operations.put;
 import static org.apache.ignite.internal.metastorage.dsl.Operations.remove;
 import static org.apache.ignite.internal.util.ArrayUtils.BYTE_EMPTY_ARRAY;
 import static org.apache.ignite.internal.util.CollectionUtils.concat;
-import static org.apache.ignite.internal.util.ExceptionUtils.unwrapCause;
+import static org.apache.ignite.internal.util.ExceptionUtils.hasCause;
 
 import java.util.List;
 import java.util.Objects;
@@ -236,11 +236,12 @@ class IndexManagementUtils {
                 
.execute(MakeIndexAvailableCommand.builder().indexId(indexId).build())
                 .whenComplete((unused, throwable) -> {
                     if (throwable != null) {
-                        Throwable unwrappedCause = unwrapCause(throwable);
-
-                        if (!(unwrappedCause instanceof 
IndexNotFoundValidationException)
-                                && !(unwrappedCause instanceof 
ChangeIndexStatusValidationException)
-                                && !(unwrappedCause instanceof 
NodeStoppingException)) {
+                        if (!hasCause(
+                                throwable,
+                                IndexNotFoundValidationException.class,
+                                ChangeIndexStatusValidationException.class,
+                                NodeStoppingException.class
+                        )) {
                             String errorMessage = "Error processing the 
command to make the index available: " + indexId;
                             failureProcessor.process(new 
FailureContext(throwable, errorMessage));
                         }

Reply via email to