This is an automated email from the ASF dual-hosted git repository.
ipavlukhin 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 c8c6c0b IGNITE-12001 Remove unreasonable assertions from
SchemaExchangeSelfTest - Fixes #6709.
c8c6c0b is described below
commit c8c6c0b1d701c27063fcf24156d4acc4523af45d
Author: pavlukhin <[email protected]>
AuthorDate: Sat Jul 20 09:23:34 2019 +0300
IGNITE-12001 Remove unreasonable assertions from SchemaExchangeSelfTest -
Fixes #6709.
Signed-off-by: ipavlukhin <[email protected]>
---
.../processors/cache/index/SchemaExchangeSelfTest.java | 11 +++++------
1 file changed, 5 insertions(+), 6 deletions(-)
diff --git
a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/index/SchemaExchangeSelfTest.java
b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/index/SchemaExchangeSelfTest.java
index eeb187b..556c238 100644
---
a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/index/SchemaExchangeSelfTest.java
+++
b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/index/SchemaExchangeSelfTest.java
@@ -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,9 +540,8 @@ 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));
- }
}
/**
@@ -552,9 +552,8 @@ 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));
- }
}
/**