# Test fix.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/cad3dde6 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/cad3dde6 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/cad3dde6 Branch: refs/heads/ignite-sql-tests Commit: cad3dde6acd552aa0dfa209b525ede51b835c281 Parents: 1b62cf4 Author: vozerov <voze...@gridgain.com> Authored: Fri Feb 20 12:13:42 2015 +0300 Committer: vozerov <voze...@gridgain.com> Committed: Fri Feb 20 12:13:42 2015 +0300 ---------------------------------------------------------------------- .../cache/distributed/GridCacheAbstractJobExecutionTest.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cad3dde6/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheAbstractJobExecutionTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheAbstractJobExecutionTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheAbstractJobExecutionTest.java index 80fed2f..6034b9f 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheAbstractJobExecutionTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheAbstractJobExecutionTest.java @@ -79,10 +79,12 @@ public abstract class GridCacheAbstractJobExecutionTest extends GridCommonAbstra /** {@inheritDoc} */ @Override protected void afterTest() throws Exception { - CacheProjection<String, int[]> cache = ((IgniteKernal)grid(0)).cache(null).flagsOn(SYNC_COMMIT). - projection(String.class, int[].class); + for (int i = 0; i < GRID_CNT; i++) { + CacheProjection<String, int[]> cache = ((IgniteKernal)grid(i)).cache(null).flagsOn(SYNC_COMMIT). + projection(String.class, int[].class); - cache.removeAll(); + cache.localRemoveAll(); + } for (int i = 0; i < GRID_CNT; i++) { Ignite g = grid(i);
