This is an automated email from the ASF dual-hosted git repository.
tkalkirill 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 1b9b6ec47f2 IGNITE-26695 Fix node fail due to
RejectedExecutionException in MetaStorageCompactionTrigger (#6761)
1b9b6ec47f2 is described below
commit 1b9b6ec47f2a89da841688dcf8e8bc460840cc3e
Author: Kirill Tkalenko <[email protected]>
AuthorDate: Tue Oct 14 15:39:42 2025 +0300
IGNITE-26695 Fix node fail due to RejectedExecutionException in
MetaStorageCompactionTrigger (#6761)
---
.../metastorage/impl/MetaStorageCompactionTrigger.java | 10 +++-------
1 file changed, 3 insertions(+), 7 deletions(-)
diff --git
a/modules/metastorage/src/main/java/org/apache/ignite/internal/metastorage/impl/MetaStorageCompactionTrigger.java
b/modules/metastorage/src/main/java/org/apache/ignite/internal/metastorage/impl/MetaStorageCompactionTrigger.java
index f2fac54a972..222a1deb0c8 100644
---
a/modules/metastorage/src/main/java/org/apache/ignite/internal/metastorage/impl/MetaStorageCompactionTrigger.java
+++
b/modules/metastorage/src/main/java/org/apache/ignite/internal/metastorage/impl/MetaStorageCompactionTrigger.java
@@ -22,13 +22,13 @@ import static
java.util.concurrent.CompletableFuture.supplyAsync;
import static java.util.concurrent.TimeUnit.MILLISECONDS;
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.ExceptionUtils.unwrapCause;
import static org.apache.ignite.internal.util.IgniteUtils.inBusyLock;
import static org.apache.ignite.internal.util.IgniteUtils.inBusyLockAsync;
import static org.apache.ignite.internal.util.IgniteUtils.inBusyLockSafe;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.Executors;
+import java.util.concurrent.RejectedExecutionException;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.TimeUnit;
@@ -306,9 +306,7 @@ public class MetaStorageCompactionTrigger implements
IgniteComponent {
.thenRunAsync(() -> storage.compact(compactionRevision),
compactionExecutor)
.whenComplete((unused, throwable) -> {
if (throwable != null) {
- Throwable cause = unwrapCause(throwable);
-
- if (!(cause instanceof NodeStoppingException)) {
+ if (!hasCause(throwable, NodeStoppingException.class,
RejectedExecutionException.class)) {
String errorMessage = String.format(
"Unknown error on new metastorage
compaction revision: %s",
compactionRevision
@@ -371,9 +369,7 @@ public class MetaStorageCompactionTrigger implements
IgniteComponent {
runAsync(() -> inBusyLockSafe(busyLock, () ->
storage.compact(recoveredCompactionRevision)), compactionExecutor)
.whenComplete((unused, throwable) -> {
if (throwable != null) {
- Throwable cause = unwrapCause(throwable);
-
- if (!(cause instanceof NodeStoppingException)) {
+ if (!hasCause(throwable,
NodeStoppingException.class, RejectedExecutionException.class)) {
String errorMessage = String.format(
"Unknown error during metastore
compaction launched on node recovery: [compactionRevision=%s]",
recoveredCompactionRevision
