Added proper exception handling to test. Fixed test.
@@ -2872,6 +2872,7 @@ public class IgniteCacheGroupsTest extends GridCommonAbstractTest {
ThreadLocalRandom rnd = ThreadLocalRandom.current();
while (!stop.get()) {
+ try {
String grp = rnd.nextBoolean() ? GROUP1 : GROUP2;
int cacheIdx = rnd.nextInt(CACHES);
@@ -2880,6 +2881,17 @@ public class IgniteCacheGroupsTest extends GridCommonAbstractTest {
for (int i = 0; i < 10; i++)
cacheOperation(rnd, cache);
}
+ catch (Exception e) {
+ if (X.hasCause(e, CacheStoppedException.class)) {
+ // Cache operation can be blocked on
+ // awaiting new topology version and cancelled with CacheStoppedException cause.
+
+ continue;
+ }
+
+ throw e;
+ }
+ }
}
catch (Exception e) {
err.set(true);
