Remove unreasonable assertions from SchemaExchangeSelfTest - Fixes
@@ -467,17 +467,18 @@ public class SchemaExchangeSelfTest extends AbstractSchemaSelfTest {
node1 = start(1, KeyClass.class, ValueClass.class, KeyClass2.class, ValueClass2.class);
assertTypes(node1, ValueClass.class, ValueClass2.class);
- assertTypes(node2, ValueClass.class);
assertCacheStarted(CACHE_NAME, node1);
reconnFut.get();
- assertTypes(node2, ValueClass.class, ValueClass2.class);
assertCacheNotStarted(CACHE_NAME, node2);
node2.cache(CACHE_NAME);
+
assertCacheStarted(CACHE_NAME, node2);
+
+ assertTypes(node2, ValueClass.class, ValueClass2.class);
}
/**
@@ -539,10 +540,9 @@ public class SchemaExchangeSelfTest extends AbstractSchemaSelfTest {
* @throws AssertionError If failed.
*/
private void assertCacheStarted(String cacheName, IgniteEx... nodes) throws AssertionError {
- for (IgniteEx node : nodes) {
+ for (IgniteEx node : nodes)
assertTrue(isCacheStarted(cacheName, node));
}
- }
/**
* Check is cache not started on the given nodes.
@@ -552,10 +552,9 @@ public class SchemaExchangeSelfTest extends AbstractSchemaSelfTest {
* @throws AssertionError If failed.
*/
private void assertCacheNotStarted(String cacheName, IgniteEx... nodes) throws AssertionError {
- for (IgniteEx node : nodes) {
+ for (IgniteEx node : nodes)
assertFalse(isCacheStarted(cacheName, node));
}
- }
/**
* Ensure that only provided types exists for the given cache.
