IGNITE-15181 Fixed IgniteClientReconnectMassiveShutdownTest.testMassiveServersShutdown3 test. Fixes #9279
diff --git a/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/IgniteClientReconnectMassiveShutdownTest.java b/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/IgniteClientReconnectMassiveShutdownTest.java
index 507b2ba..918af7e 100644
--- a/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/IgniteClientReconnectMassiveShutdownTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/IgniteClientReconnectMassiveShutdownTest.java
@@ -38,6 +38,7 @@
import org.apache.ignite.configuration.CacheConfiguration;
import org.apache.ignite.configuration.IgniteConfiguration;
import org.apache.ignite.internal.IgniteInternalFuture;
+import org.apache.ignite.internal.processors.cache.CacheInvalidStateException;
import org.apache.ignite.internal.util.future.IgniteFinishedFutureImpl;
import org.apache.ignite.internal.util.typedef.X;
import org.apache.ignite.internal.util.typedef.internal.SB;
@@ -291,9 +292,8 @@
// Clean up ignite instance from static map in IgnitionEx.grids
if (stopType == StopType.SIMULATE_FAIL) {
- for (int i = 0; i < srvsToKill; i++) {
+ for (int i = 0; i < srvsToKill; i++)
grid(i).close();
- }
}
awaitPartitionMapExchange();
@@ -363,6 +363,10 @@
return cause.retryReadyFuture();
}
+ else if (X.hasCause(e, CacheInvalidStateException.class)) {
+ // All partition owners have left the cluster, partition data has been lost.
+ return new IgniteFinishedFutureImpl<>();
+ }
else
throw e;
}
