You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sk...@apache.org on 2021/07/30 10:10:52 UTC
[ignite] branch master updated: IGNITE-15181 Fixed
IgniteClientReconnectMassiveShutdownTest.testMassiveServersShutdown3 test.
Fixes #9279
This is an automated email from the ASF dual-hosted git repository.
sk0x50 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/master by this push:
new 7396775 IGNITE-15181 Fixed IgniteClientReconnectMassiveShutdownTest.testMassiveServersShutdown3 test. Fixes #9279
7396775 is described below
commit 73967750f5d29a820fb2d5c1e33b7d8f90ddd066
Author: Slava Koptilin <sl...@gmail.com>
AuthorDate: Fri Jul 30 12:58:44 2021 +0300
IGNITE-15181 Fixed IgniteClientReconnectMassiveShutdownTest.testMassiveServersShutdown3 test. Fixes #9279
---
.../discovery/tcp/IgniteClientReconnectMassiveShutdownTest.java | 8 ++++++--
1 file changed, 6 insertions(+), 2 deletions(-)
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.cluster.ClusterTopologyException;
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 @@ public class IgniteClientReconnectMassiveShutdownTest extends GridCommonAbstract
// 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 @@ public class IgniteClientReconnectMassiveShutdownTest extends GridCommonAbstract
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;
}