Fixed ZK discovery IgniteCacheReplicatedQuerySelfTest.testNodeLeft test
@@ -46,11 +46,11 @@ import org.apache.ignite.internal.util.typedef.internal.S;
import org.apache.ignite.internal.util.typedef.internal.U;
import org.apache.ignite.lang.IgnitePredicate;
import org.apache.ignite.testframework.GridTestUtils;
-import org.apache.ignite.testsuites.IgniteIgnore;
import org.apache.ignite.transactions.Transaction;
import static org.apache.ignite.cache.CacheMode.REPLICATED;
import static org.apache.ignite.cache.CachePeekMode.ALL;
+import static org.apache.ignite.events.EventType.EVT_NODE_FAILED;
import static org.apache.ignite.events.EventType.EVT_NODE_LEFT;
/**
@@ -333,14 +333,13 @@ public class IgniteCacheReplicatedQuerySelfTest extends IgniteCacheAbstractQuery
/**
* @throws Exception If failed.
*/
- @IgniteIgnore(value = "https://issues.apache.org/jira/browse/IGNITE-613", forceFailure = true)
public void testNodeLeft() throws Exception {
Ignite g = startGrid("client");
try {
assertTrue(g.configuration().isClientMode());
- IgniteCache<Integer, Integer> cache = jcache(Integer.class, Integer.class);
+ IgniteCache<Integer, Integer> cache = jcache(g, Integer.class, Integer.class);
for (int i = 0; i < 1000; i++)
cache.put(i, i);
@@ -371,7 +370,7 @@ public class IgniteCacheReplicatedQuerySelfTest extends IgniteCacheAbstractQuery
return true;
}
- }, EVT_NODE_LEFT);
+ }, EVT_NODE_LEFT, EVT_NODE_FAILED);
stopGrid("client");
