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));
}