http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheAtomicReferenceMultiNodeAbstractTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheAtomicReferenceMultiNodeAbstractTest.java b/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheAtomicReferenceMultiNodeAbstractTest.java index 1f74249..9badb83 100644 --- a/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheAtomicReferenceMultiNodeAbstractTest.java +++ b/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheAtomicReferenceMultiNodeAbstractTest.java @@ -89,7 +89,7 @@ public abstract class GridCacheAtomicReferenceMultiNodeAbstractTest extends Grid // Execute task on all grid nodes. ignite.compute().call(new IgniteCallable<Object>() { - @Override public String call() throws IgniteCheckedException { + @Override public String call() throws IgniteException { GridCacheAtomicReference<String> ref = ignite.cache(null).dataStructures().atomicReference(refName, val, true); assertEquals(val, ref.get()); @@ -102,7 +102,7 @@ public abstract class GridCacheAtomicReferenceMultiNodeAbstractTest extends Grid // Execute task on all grid nodes. ignite.compute().call(new IgniteCallable<String>() { - @Override public String call() throws IgniteCheckedException { + @Override public String call() throws IgniteException { GridCacheAtomicReference<String> ref = ignite.cache(null).dataStructures().atomicReference(refName, val, true); assertEquals(val, ref.get()); @@ -115,7 +115,7 @@ public abstract class GridCacheAtomicReferenceMultiNodeAbstractTest extends Grid // Execute task on all grid nodes. ignite.compute().call(new IgniteCallable<String>() { - @Override public String call() throws IgniteCheckedException { + @Override public String call() throws IgniteException { GridCacheAtomicReference<String> ref = ignite.cache(null).dataStructures().atomicReference(refName, val, true); assertEquals(newVal, ref.get()); @@ -150,7 +150,7 @@ public abstract class GridCacheAtomicReferenceMultiNodeAbstractTest extends Grid // Execute task on all grid nodes. ignite.compute().call(new IgniteCallable<String>() { - @Override public String call() throws IgniteCheckedException { + @Override public String call() throws IgniteException { GridCacheAtomicStamped<String, String> stamped = ignite.cache(null).dataStructures() .atomicStamped(stampedName, val, stamp, true); @@ -165,7 +165,7 @@ public abstract class GridCacheAtomicReferenceMultiNodeAbstractTest extends Grid // Execute task on all grid nodes. ignite.compute().call(new IgniteCallable<String>() { - @Override public String call() throws IgniteCheckedException { + @Override public String call() throws IgniteException { GridCacheAtomicStamped<String, String> stamped = ignite.cache(null).dataStructures() .atomicStamped(stampedName, val, stamp, true); @@ -180,7 +180,7 @@ public abstract class GridCacheAtomicReferenceMultiNodeAbstractTest extends Grid // Execute task on all grid nodes. ignite.compute().call(new IgniteCallable<String>() { - @Override public String call() throws IgniteCheckedException { + @Override public String call() throws IgniteException { GridCacheAtomicStamped<String, String> stamped = ignite.cache(null).dataStructures() .atomicStamped(stampedName, val, stamp, true);
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheQueueMultiNodeAbstractSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheQueueMultiNodeAbstractSelfTest.java b/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheQueueMultiNodeAbstractSelfTest.java index acca39c..7c335bf 100644 --- a/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheQueueMultiNodeAbstractSelfTest.java +++ b/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheQueueMultiNodeAbstractSelfTest.java @@ -642,7 +642,7 @@ public abstract class GridCacheQueueMultiNodeAbstractSelfTest extends GridCommon } /** {@inheritDoc} */ - @Override public Integer call() throws IgniteCheckedException { + @Override public Integer call() throws IgniteException { assertNotNull(ignite); ignite.log().info("Running job [node=" + ignite.cluster().localNode().id() + ", job=" + this + "]"); @@ -689,7 +689,7 @@ public abstract class GridCacheQueueMultiNodeAbstractSelfTest extends GridCommon } /** {@inheritDoc} */ - @Override public Integer call() throws IgniteCheckedException { + @Override public Integer call() throws IgniteException { assertNotNull(ignite); ignite.log().info("Running job [node=" + ignite.cluster().localNode().id() + ", job=" + this + "]"); @@ -745,7 +745,7 @@ public abstract class GridCacheQueueMultiNodeAbstractSelfTest extends GridCommon } /** {@inheritDoc} */ - @Override public Integer call() throws IgniteCheckedException { + @Override public Integer call() throws IgniteException { assertNotNull(ignite); ignite.log().info("Running job [node=" + ignite.cluster().localNode().id() + ", job=" + this + "]"); @@ -797,7 +797,7 @@ public abstract class GridCacheQueueMultiNodeAbstractSelfTest extends GridCommon } /** {@inheritDoc} */ - @Override public Integer call() throws IgniteCheckedException { + @Override public Integer call() throws IgniteException { assertNotNull(ignite); ignite.log().info("Running job [node=" + ignite.cluster().localNode().id() + ", job=" + this + ']'); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheQueueRotativeMultiNodeAbstractTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheQueueRotativeMultiNodeAbstractTest.java b/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheQueueRotativeMultiNodeAbstractTest.java index e2f51d6..7fe2792 100644 --- a/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheQueueRotativeMultiNodeAbstractTest.java +++ b/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheQueueRotativeMultiNodeAbstractTest.java @@ -209,7 +209,7 @@ public abstract class GridCacheQueueRotativeMultiNodeAbstractTest extends GridCo } /** {@inheritDoc} */ - @Override public Integer call() throws IgniteCheckedException { + @Override public Integer call() throws IgniteException { assertNotNull(ignite); ignite.log().info("Running job [node=" + ignite.cluster().localNode().id() + ", job=" + this + "]"); @@ -261,7 +261,7 @@ public abstract class GridCacheQueueRotativeMultiNodeAbstractTest extends GridCo } /** {@inheritDoc} */ - @Override public Integer call() throws IgniteCheckedException { + @Override public Integer call() throws IgniteException { assertNotNull(ignite); ignite.log().info("Running job [node=" + ignite.cluster().localNode().id() + ", job=" + this + "]"); @@ -313,7 +313,7 @@ public abstract class GridCacheQueueRotativeMultiNodeAbstractTest extends GridCo } /** {@inheritDoc} */ - @Override public Integer call() throws IgniteCheckedException { + @Override public Integer call() throws IgniteException { assertNotNull(ignite); ignite.log().info("Running job [node=" + ignite.cluster().localNode().id() + ", job=" + this + ']'); @@ -361,7 +361,7 @@ public abstract class GridCacheQueueRotativeMultiNodeAbstractTest extends GridCo } /** {@inheritDoc} */ - @Override public Boolean call() throws IgniteCheckedException { + @Override public Boolean call() throws IgniteException { assertNotNull(ignite); ignite.log().info("Running job [node=" + ignite.cluster().localNode().id() + ", job=" + this + ']'); @@ -409,7 +409,7 @@ public abstract class GridCacheQueueRotativeMultiNodeAbstractTest extends GridCo } /** {@inheritDoc} */ - @Override public Boolean call() throws IgniteCheckedException { + @Override public Boolean call() throws IgniteException { assertNotNull(ignite); ignite.log().info("Running job [node=" + ignite.cluster().localNode().id() + ", job=" + this + "]"); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheSequenceMultiNodeAbstractSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheSequenceMultiNodeAbstractSelfTest.java b/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheSequenceMultiNodeAbstractSelfTest.java index 9077edf..c8e2ad7 100644 --- a/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheSequenceMultiNodeAbstractSelfTest.java +++ b/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/datastructures/GridCacheSequenceMultiNodeAbstractSelfTest.java @@ -195,7 +195,7 @@ public abstract class GridCacheSequenceMultiNodeAbstractSelfTest extends GridCom } /** {@inheritDoc} */ - @Override public Set<Long> call() throws IgniteCheckedException { + @Override public Set<Long> call() throws IgniteException { assert ignite != null; if (log.isInfoEnabled()) @@ -249,7 +249,7 @@ public abstract class GridCacheSequenceMultiNodeAbstractSelfTest extends GridCom } /** {@inheritDoc} */ - @Override public Set<Long> call() throws IgniteCheckedException { + @Override public Set<Long> call() throws IgniteException { assert ignite != null; if (log.isInfoEnabled()) http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/datastructures/partitioned/GridCachePartitionedQueueEntryMoveSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/datastructures/partitioned/GridCachePartitionedQueueEntryMoveSelfTest.java b/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/datastructures/partitioned/GridCachePartitionedQueueEntryMoveSelfTest.java index 05f65df..a399a81 100644 --- a/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/datastructures/partitioned/GridCachePartitionedQueueEntryMoveSelfTest.java +++ b/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/datastructures/partitioned/GridCachePartitionedQueueEntryMoveSelfTest.java @@ -94,7 +94,7 @@ public class GridCachePartitionedQueueEntryMoveSelfTest extends GridCommonAbstra //final CountDownLatch latch2 = new CountDownLatch(1); IgniteFuture<?> fut1 = GridTestUtils.runAsync(new Callable<Void>() { - @Override public Void call() throws IgniteCheckedException { + @Override public Void call() throws IgniteException { Ignite ignite = grid(0); GridCacheQueue<Integer> queue = ignite.cache(null).dataStructures().queue(queueName, QUEUE_CAP, @@ -134,7 +134,7 @@ public class GridCachePartitionedQueueEntryMoveSelfTest extends GridCommonAbstra //latch2.countDown(); IgniteFuture<?> fut2 = GridTestUtils.runAsync(new Callable<Void>() { - @Override public Void call() throws IgniteCheckedException { + @Override public Void call() throws IgniteException { Ignite ignite = grid(GRID_CNT); GridCacheQueue<Integer> queue = ignite.cache(null).dataStructures(). http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/distributed/dht/GridCacheDhtPreloadBigDataSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/distributed/dht/GridCacheDhtPreloadBigDataSelfTest.java b/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/distributed/dht/GridCacheDhtPreloadBigDataSelfTest.java index 75728b8..f6669a6 100644 --- a/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/distributed/dht/GridCacheDhtPreloadBigDataSelfTest.java +++ b/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/distributed/dht/GridCacheDhtPreloadBigDataSelfTest.java @@ -158,7 +158,7 @@ public class GridCacheDhtPreloadBigDataSelfTest extends GridCommonAbstractTest { @IgniteInstanceResource private Ignite ignite; - @Override public void onLifecycleEvent(LifecycleEventType evt) throws IgniteCheckedException { + @Override public void onLifecycleEvent(LifecycleEventType evt) throws IgniteException { if (evt == LifecycleEventType.AFTER_GRID_START) { GridCache<Integer, byte[]> c = ignite.cache(null); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/distributed/dht/GridCacheDhtPreloadUnloadSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/distributed/dht/GridCacheDhtPreloadUnloadSelfTest.java b/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/distributed/dht/GridCacheDhtPreloadUnloadSelfTest.java index a1d6922..8185447 100644 --- a/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/distributed/dht/GridCacheDhtPreloadUnloadSelfTest.java +++ b/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/distributed/dht/GridCacheDhtPreloadUnloadSelfTest.java @@ -256,7 +256,7 @@ public class GridCacheDhtPreloadUnloadSelfTest extends GridCommonAbstractTest { @IgniteInstanceResource private Ignite ignite; - @Override public void onLifecycleEvent(LifecycleEventType evt) throws IgniteCheckedException { + @Override public void onLifecycleEvent(LifecycleEventType evt) throws IgniteException { if (evt == LifecycleEventType.AFTER_GRID_START) { GridCache<Integer, String> c = ignite.cache(null); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/distributed/near/GridCachePartitionedMultiNodeCounterSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/distributed/near/GridCachePartitionedMultiNodeCounterSelfTest.java b/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/distributed/near/GridCachePartitionedMultiNodeCounterSelfTest.java index 2379063..32d8409 100644 --- a/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/distributed/near/GridCachePartitionedMultiNodeCounterSelfTest.java +++ b/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/distributed/near/GridCachePartitionedMultiNodeCounterSelfTest.java @@ -599,7 +599,7 @@ public class GridCachePartitionedMultiNodeCounterSelfTest extends GridCommonAbst } /** {@inheritDoc} */ - @Override public Boolean call() throws IgniteCheckedException, InterruptedException { + @Override public Boolean call() throws IgniteException, InterruptedException { assertNotNull(ignite); startLatchMultiNode.countDown(); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/distributed/near/GridCachePartitionedPreloadLifecycleSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/distributed/near/GridCachePartitionedPreloadLifecycleSelfTest.java b/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/distributed/near/GridCachePartitionedPreloadLifecycleSelfTest.java index e963d72..a1b3425 100644 --- a/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/distributed/near/GridCachePartitionedPreloadLifecycleSelfTest.java +++ b/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/distributed/near/GridCachePartitionedPreloadLifecycleSelfTest.java @@ -73,7 +73,7 @@ public class GridCachePartitionedPreloadLifecycleSelfTest extends GridCachePrelo @IgniteInstanceResource private Ignite ignite; - @Override public void onLifecycleEvent(LifecycleEventType evt) throws IgniteCheckedException { + @Override public void onLifecycleEvent(LifecycleEventType evt) throws IgniteException { switch (evt) { case AFTER_GRID_START: { GridCache<Object, MyValue> c1 = ignite.cache("one"); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/distributed/replicated/preloader/GridCacheReplicatedPreloadLifecycleSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/distributed/replicated/preloader/GridCacheReplicatedPreloadLifecycleSelfTest.java b/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/distributed/replicated/preloader/GridCacheReplicatedPreloadLifecycleSelfTest.java index 696e47f..4043c01 100644 --- a/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/distributed/replicated/preloader/GridCacheReplicatedPreloadLifecycleSelfTest.java +++ b/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/distributed/replicated/preloader/GridCacheReplicatedPreloadLifecycleSelfTest.java @@ -75,7 +75,7 @@ public class GridCacheReplicatedPreloadLifecycleSelfTest extends GridCachePreloa @IgniteInstanceResource private Ignite ignite; - @Override public void onLifecycleEvent(LifecycleEventType evt) throws IgniteCheckedException { + @Override public void onLifecycleEvent(LifecycleEventType evt) throws IgniteException { switch (evt) { case AFTER_GRID_START: { GridCache<Object, MyValue> c1 = ignite.cache("one"); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/eviction/random/GridCacheRandomEvictionPolicySelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/eviction/random/GridCacheRandomEvictionPolicySelfTest.java b/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/eviction/random/GridCacheRandomEvictionPolicySelfTest.java index a90fb8e..09eb0bc 100644 --- a/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/eviction/random/GridCacheRandomEvictionPolicySelfTest.java +++ b/modules/core/src/test/java/org/gridgain/grid/kernal/processors/cache/eviction/random/GridCacheRandomEvictionPolicySelfTest.java @@ -176,7 +176,7 @@ public class GridCacheRandomEvictionPolicySelfTest extends t[i] = Integer.toString(i); multithreaded(new Callable() { - @Nullable @Override public Object call() throws IgniteCheckedException { + @Nullable @Override public Object call() throws IgniteException { int runs = 3000; for (int i = 0; i < runs; i++) { http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/kernal/processors/clock/GridTimeSyncProcessorSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/kernal/processors/clock/GridTimeSyncProcessorSelfTest.java b/modules/core/src/test/java/org/gridgain/grid/kernal/processors/clock/GridTimeSyncProcessorSelfTest.java index 4792bd6..b76ae11 100644 --- a/modules/core/src/test/java/org/gridgain/grid/kernal/processors/clock/GridTimeSyncProcessorSelfTest.java +++ b/modules/core/src/test/java/org/gridgain/grid/kernal/processors/clock/GridTimeSyncProcessorSelfTest.java @@ -188,7 +188,7 @@ public class GridTimeSyncProcessorSelfTest extends GridCommonAbstractTest { } /** {@inheritDoc} */ - @Override public void onLifecycleEvent(LifecycleEventType evt) throws IgniteCheckedException { + @Override public void onLifecycleEvent(LifecycleEventType evt) throws IgniteException { if (evt == LifecycleEventType.BEFORE_GRID_START) ((GridKernalContextImpl)((GridKernal)g).context()).timeSource(new TimeShiftClockSource(delta)); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsFileInfoSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsFileInfoSelfTest.java b/modules/core/src/test/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsFileInfoSelfTest.java index 7b79d70..cae7c61 100644 --- a/modules/core/src/test/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsFileInfoSelfTest.java +++ b/modules/core/src/test/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsFileInfoSelfTest.java @@ -38,7 +38,7 @@ public class GridGgfsFileInfoSelfTest extends GridGgfsCommonAbstractTest { private final Random rnd = new Random(); @SuppressWarnings("deprecation") // Suppress due to default constructor should never be used directly. - @Nullable @Override public Object call() throws IgniteCheckedException { + @Nullable @Override public Object call() throws IgniteException { for (int i = 0; i < 10000; i++) { testSerialization(new GridGgfsFileInfo()); testSerialization(new GridGgfsFileInfo()); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsTaskSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsTaskSelfTest.java b/modules/core/src/test/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsTaskSelfTest.java index 68ac49f..1a10498 100644 --- a/modules/core/src/test/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsTaskSelfTest.java +++ b/modules/core/src/test/java/org/gridgain/grid/kernal/processors/ggfs/GridGgfsTaskSelfTest.java @@ -231,12 +231,12 @@ public class GridGgfsTaskSelfTest extends GridGgfsCommonAbstractTest { private static class Task extends IgniteFsTask<String, IgniteBiTuple<Long, Integer>> { /** {@inheritDoc} */ @Override public IgniteFsJob createJob(IgniteFsPath path, IgniteFsFileRange range, - IgniteFsTaskArgs<String> args) throws IgniteCheckedException { + IgniteFsTaskArgs<String> args) throws IgniteException { return new Job(); } /** {@inheritDoc} */ - @Override public IgniteBiTuple<Long, Integer> reduce(List<ComputeJobResult> ress) throws IgniteCheckedException { + @Override public IgniteBiTuple<Long, Integer> reduce(List<ComputeJobResult> ress) throws IgniteException { long totalLen = 0; int argCnt = 0; @@ -268,7 +268,7 @@ public class GridGgfsTaskSelfTest extends GridGgfsCommonAbstractTest { /** {@inheritDoc} */ @Override public Object execute(IgniteFs ggfs, IgniteFsFileRange range, IgniteFsInputStream in) - throws IgniteCheckedException, IOException { + throws IgniteException, IOException { assert ignite != null; assert ses != null; assert ctx != null; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/kernal/processors/streamer/GridTestStage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/kernal/processors/streamer/GridTestStage.java b/modules/core/src/test/java/org/gridgain/grid/kernal/processors/streamer/GridTestStage.java index 456db60..a23d249 100644 --- a/modules/core/src/test/java/org/gridgain/grid/kernal/processors/streamer/GridTestStage.java +++ b/modules/core/src/test/java/org/gridgain/grid/kernal/processors/streamer/GridTestStage.java @@ -40,7 +40,7 @@ class GridTestStage implements StreamerStage<Object> { /** {@inheritDoc} */ @Override public Map<String, Collection<?>> run(StreamerContext ctx, Collection<Object> evts) - throws IgniteCheckedException { + throws IgniteException { return stageClos.apply(name(), ctx, evts); } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/loadtest/GridSingleExecutionTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/loadtest/GridSingleExecutionTest.java b/modules/core/src/test/java/org/gridgain/grid/loadtest/GridSingleExecutionTest.java index 4ab1cd4..0f1ae10 100644 --- a/modules/core/src/test/java/org/gridgain/grid/loadtest/GridSingleExecutionTest.java +++ b/modules/core/src/test/java/org/gridgain/grid/loadtest/GridSingleExecutionTest.java @@ -235,7 +235,7 @@ public final class GridSingleExecutionTest { /** */ public static class TestTask extends ComputeTaskSplitAdapter<Object, Object> { /** {@inheritDoc} */ - @Override protected Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteCheckedException { + @Override protected Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteException { Collection<ComputeJob> jobs = new ArrayList<>(JOB_COUNT); for (int i = 0; i < JOB_COUNT; i++) { @@ -243,7 +243,7 @@ public final class GridSingleExecutionTest { @IgniteLoggerResource private IgniteLogger log; - @Override public Serializable execute() throws IgniteCheckedException { + @Override public Serializable execute() throws IgniteException { if (log.isInfoEnabled()) log.info("Executing job [index=" + argument(0) + ']'); @@ -256,7 +256,7 @@ public final class GridSingleExecutionTest { } /** {@inheritDoc} */ - @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Object reduce(List<ComputeJobResult> results) throws IgniteException { assert results != null : "Unexpected result [results=" + results + ']'; assert results.size() == JOB_COUNT : "Unexpected result [results=" + results + ']'; @@ -271,7 +271,7 @@ public final class GridSingleExecutionTest { private ComputeTaskSession ses; /** {@inheritDoc} */ - @Override protected Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteCheckedException { + @Override protected Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteException { Collection<ComputeJob> jobs = new ArrayList<>(JOB_COUNT); for (int i = 0; i < JOB_COUNT; i++) { @@ -279,7 +279,7 @@ public final class GridSingleExecutionTest { @IgniteLoggerResource private IgniteLogger log; - @Override public Serializable execute() throws IgniteCheckedException { + @Override public Serializable execute() throws IgniteException { if (log.isInfoEnabled()) log.info("Executing job [index=" + argument(0) + ']'); @@ -299,7 +299,7 @@ public final class GridSingleExecutionTest { /** {@inheritDoc} */ @Override public ComputeJobResultPolicy result(ComputeJobResult res, - List<ComputeJobResult> received) throws IgniteCheckedException { + List<ComputeJobResult> received) throws IgniteException { ses.setAttribute("attr7", 7); ses.setAttribute("attr8", 8); @@ -307,7 +307,7 @@ public final class GridSingleExecutionTest { } /** {@inheritDoc} */ - @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Object reduce(List<ComputeJobResult> results) throws IgniteException { assert results != null : "Unexpected result [results=" + results + ']'; assert results.size() == JOB_COUNT : "Unexpected result [results=" + results + ']'; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/p2p/GridP2PJobClassLoaderSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/p2p/GridP2PJobClassLoaderSelfTest.java b/modules/core/src/test/java/org/gridgain/grid/p2p/GridP2PJobClassLoaderSelfTest.java index 6ca5e49..86b0715 100644 --- a/modules/core/src/test/java/org/gridgain/grid/p2p/GridP2PJobClassLoaderSelfTest.java +++ b/modules/core/src/test/java/org/gridgain/grid/p2p/GridP2PJobClassLoaderSelfTest.java @@ -114,7 +114,7 @@ public class GridP2PJobClassLoaderSelfTest extends GridCommonAbstractTest { private static ClassLoader ldr; /** {@inheritDoc} */ - @Override protected Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteCheckedException { + @Override protected Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteException { assert rsrcTask != null; assert gridSize == 1; @@ -128,7 +128,7 @@ public class GridP2PJobClassLoaderSelfTest extends GridCommonAbstractTest { /** {@inheritDoc} */ @SuppressWarnings({"ObjectEquality"}) - public Serializable execute() throws IgniteCheckedException { + public Serializable execute() throws IgniteException { assert rsrcJob == rsrcTask; assert getClass().getClassLoader() == ldr; @@ -139,7 +139,7 @@ public class GridP2PJobClassLoaderSelfTest extends GridCommonAbstractTest { } /** {@inheritDoc} */ - @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Object reduce(List<ComputeJobResult> results) throws IgniteException { assert rsrcTask != null; // Nothing to reduce. http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/p2p/GridP2PLocalDeploymentSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/p2p/GridP2PLocalDeploymentSelfTest.java b/modules/core/src/test/java/org/gridgain/grid/p2p/GridP2PLocalDeploymentSelfTest.java index 33b2a57..3f3339b 100644 --- a/modules/core/src/test/java/org/gridgain/grid/p2p/GridP2PLocalDeploymentSelfTest.java +++ b/modules/core/src/test/java/org/gridgain/grid/p2p/GridP2PLocalDeploymentSelfTest.java @@ -221,7 +221,7 @@ public class GridP2PLocalDeploymentSelfTest extends GridCommonAbstractTest { /** {@inheritDoc} */ @Override public Map<? extends ComputeJob, ClusterNode> map(final List<ClusterNode> subgrid, UUID arg) - throws IgniteCheckedException { + throws IgniteException { taskRsrc = rsrc; @@ -236,7 +236,7 @@ public class GridP2PLocalDeploymentSelfTest extends GridCommonAbstractTest { } /** {@inheritDoc} */ - @Override public int[] reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public int[] reduce(List<ComputeJobResult> results) throws IgniteException { assert results.size() == 1; assert taskRsrc == rsrc; @@ -263,7 +263,7 @@ public class GridP2PLocalDeploymentSelfTest extends GridCommonAbstractTest { public TestJob(UUID nodeId) { super(nodeId); } /** {@inheritDoc} */ - @Override public Serializable execute() throws IgniteCheckedException { + @Override public Serializable execute() throws IgniteException { assert locNodeId.equals(argument(0)) == true; jobRsrc = rsrc; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/p2p/GridP2PRecursionTaskSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/p2p/GridP2PRecursionTaskSelfTest.java b/modules/core/src/test/java/org/gridgain/grid/p2p/GridP2PRecursionTaskSelfTest.java index 46bab5b..87d690d 100644 --- a/modules/core/src/test/java/org/gridgain/grid/p2p/GridP2PRecursionTaskSelfTest.java +++ b/modules/core/src/test/java/org/gridgain/grid/p2p/GridP2PRecursionTaskSelfTest.java @@ -122,7 +122,7 @@ public class GridP2PRecursionTaskSelfTest extends GridCommonAbstractTest { */ public static class FactorialTask extends ComputeTaskAdapter<Long, Long> { /** {@inheritDoc} */ - @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, Long arg) throws IgniteCheckedException { + @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, Long arg) throws IgniteException { assert arg > 1; Map<FactorialJob, ClusterNode> map = new HashMap<>(); @@ -143,7 +143,7 @@ public class GridP2PRecursionTaskSelfTest extends GridCommonAbstractTest { } /** {@inheritDoc} */ - @Override public Long reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Long reduce(List<ComputeJobResult> results) throws IgniteException { long retVal = 0; for (ComputeJobResult res : results) { @@ -169,7 +169,7 @@ public class GridP2PRecursionTaskSelfTest extends GridCommonAbstractTest { } /** {@inheritDoc} */ - @Override public Long execute() throws IgniteCheckedException { + @Override public Long execute() throws IgniteException { Long arg = argument(0); assert arg != null; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/p2p/GridP2PRemoteClassLoadersSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/p2p/GridP2PRemoteClassLoadersSelfTest.java b/modules/core/src/test/java/org/gridgain/grid/p2p/GridP2PRemoteClassLoadersSelfTest.java index 4d8dd23..7c332a5 100644 --- a/modules/core/src/test/java/org/gridgain/grid/p2p/GridP2PRemoteClassLoadersSelfTest.java +++ b/modules/core/src/test/java/org/gridgain/grid/p2p/GridP2PRemoteClassLoadersSelfTest.java @@ -219,7 +219,7 @@ public class GridP2PRemoteClassLoadersSelfTest extends GridCommonAbstractTest { } /** {@inheritDoc} */ - @Override public Serializable execute() throws IgniteCheckedException { + @Override public Serializable execute() throws IgniteException { // Return next value. return GridP2PTestStaticVariable.staticVar++; } @@ -239,7 +239,7 @@ public class GridP2PRemoteClassLoadersSelfTest extends GridCommonAbstractTest { /** {@inheritDoc} */ @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, Serializable arg) - throws IgniteCheckedException { + throws IgniteException { Map<ComputeJob, ClusterNode> map = new HashMap<>(subgrid.size()); for (ClusterNode node : subgrid) { @@ -251,7 +251,7 @@ public class GridP2PRemoteClassLoadersSelfTest extends GridCommonAbstractTest { } /** {@inheritDoc} */ - @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Object reduce(List<ComputeJobResult> results) throws IgniteException { assert results.size() == 1; ComputeJobResult res = results.get(0); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/p2p/GridP2PTestJob.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/p2p/GridP2PTestJob.java b/modules/core/src/test/java/org/gridgain/grid/p2p/GridP2PTestJob.java index a38c768..bb7aa8b 100644 --- a/modules/core/src/test/java/org/gridgain/grid/p2p/GridP2PTestJob.java +++ b/modules/core/src/test/java/org/gridgain/grid/p2p/GridP2PTestJob.java @@ -41,7 +41,7 @@ public class GridP2PTestJob extends ComputeJobAdapter { } /** {@inheritDoc} */ - @Override public Serializable execute() throws IgniteCheckedException { + @Override public Serializable execute() throws IgniteException { assert taskSes != null; ClassLoader ldr = getClass().getClassLoader(); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/p2p/GridP2PTestTask.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/p2p/GridP2PTestTask.java b/modules/core/src/test/java/org/gridgain/grid/p2p/GridP2PTestTask.java index d4050a8..90d7eb7 100644 --- a/modules/core/src/test/java/org/gridgain/grid/p2p/GridP2PTestTask.java +++ b/modules/core/src/test/java/org/gridgain/grid/p2p/GridP2PTestTask.java @@ -34,7 +34,7 @@ public class GridP2PTestTask extends ComputeTaskAdapter<Object, Integer> { private UUID nodeId; /** {@inheritDoc} */ - @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, Object arg) throws IgniteCheckedException { + @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, Object arg) throws IgniteException { assert subgrid != null; assert !subgrid.isEmpty(); @@ -57,7 +57,7 @@ public class GridP2PTestTask extends ComputeTaskAdapter<Object, Integer> { } /** {@inheritDoc} */ - @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteException { assert results.size() == 1 : "Results [received=" + results.size() + ", expected=" + 1 + ']'; ComputeJobResult res = results.get(0); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/session/GridSessionCancelSiblingsFromFutureSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/session/GridSessionCancelSiblingsFromFutureSelfTest.java b/modules/core/src/test/java/org/gridgain/grid/session/GridSessionCancelSiblingsFromFutureSelfTest.java index 859d690..ac5411a 100644 --- a/modules/core/src/test/java/org/gridgain/grid/session/GridSessionCancelSiblingsFromFutureSelfTest.java +++ b/modules/core/src/test/java/org/gridgain/grid/session/GridSessionCancelSiblingsFromFutureSelfTest.java @@ -193,7 +193,7 @@ public class GridSessionCancelSiblingsFromFutureSelfTest extends GridCommonAbstr private volatile int taskNum = -1; /** {@inheritDoc} */ - @Override protected Collection<? extends ComputeJob> split(int gridSize, Serializable arg) throws IgniteCheckedException { + @Override protected Collection<? extends ComputeJob> split(int gridSize, Serializable arg) throws IgniteException { if (log.isInfoEnabled()) log.info("Splitting jobs [task=" + this + ", gridSize=" + gridSize + ", arg=" + arg + ']'); @@ -252,7 +252,7 @@ public class GridSessionCancelSiblingsFromFutureSelfTest extends GridCommonAbstr } /** {@inheritDoc} */ - @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) throws IgniteCheckedException { + @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) throws IgniteException { if (log.isInfoEnabled()) log.info("Received job result [job=" + this + ", result=" + res + ']'); @@ -260,7 +260,7 @@ public class GridSessionCancelSiblingsFromFutureSelfTest extends GridCommonAbstr } /** {@inheritDoc} */ - @Override public String reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public String reduce(List<ComputeJobResult> results) throws IgniteException { if (log.isInfoEnabled()) log.info("Aggregating job [job=" + this + ", results=" + results + ']'); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/session/GridSessionCancelSiblingsFromJobSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/session/GridSessionCancelSiblingsFromJobSelfTest.java b/modules/core/src/test/java/org/gridgain/grid/session/GridSessionCancelSiblingsFromJobSelfTest.java index 56d1b49..0296cfc 100644 --- a/modules/core/src/test/java/org/gridgain/grid/session/GridSessionCancelSiblingsFromJobSelfTest.java +++ b/modules/core/src/test/java/org/gridgain/grid/session/GridSessionCancelSiblingsFromJobSelfTest.java @@ -180,7 +180,7 @@ public class GridSessionCancelSiblingsFromJobSelfTest extends GridCommonAbstract private volatile int taskNum = -1; /** {@inheritDoc} */ - @Override protected Collection<? extends ComputeJob> split(int gridSize, Serializable arg) throws IgniteCheckedException { + @Override protected Collection<? extends ComputeJob> split(int gridSize, Serializable arg) throws IgniteException { if (log.isInfoEnabled()) log.info("Splitting job [task=" + this + ", gridSize=" + gridSize + ", arg=" + arg + ']'); @@ -203,7 +203,7 @@ public class GridSessionCancelSiblingsFromJobSelfTest extends GridCommonAbstract /** {@inheritDoc} */ @SuppressWarnings({"BusyWait"}) - @Override public Object execute() throws IgniteCheckedException { + @Override public Object execute() throws IgniteException { assert taskSes != null; thread = Thread.currentThread(); @@ -266,12 +266,12 @@ public class GridSessionCancelSiblingsFromJobSelfTest extends GridCommonAbstract /** {@inheritDoc} */ @Override public ComputeJobResultPolicy result(ComputeJobResult result, List<ComputeJobResult> received) - throws IgniteCheckedException { + throws IgniteException { return received.size() == SPLIT_COUNT ? ComputeJobResultPolicy.REDUCE : ComputeJobResultPolicy.WAIT; } /** {@inheritDoc} */ - @Override public String reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public String reduce(List<ComputeJobResult> results) throws IgniteException { if (log.isInfoEnabled()) log.info("Aggregating job [job=" + this + ", results=" + results + ']'); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/session/GridSessionCancelSiblingsFromTaskSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/session/GridSessionCancelSiblingsFromTaskSelfTest.java b/modules/core/src/test/java/org/gridgain/grid/session/GridSessionCancelSiblingsFromTaskSelfTest.java index 3e7c8a8..b7080cb 100644 --- a/modules/core/src/test/java/org/gridgain/grid/session/GridSessionCancelSiblingsFromTaskSelfTest.java +++ b/modules/core/src/test/java/org/gridgain/grid/session/GridSessionCancelSiblingsFromTaskSelfTest.java @@ -187,7 +187,7 @@ public class GridSessionCancelSiblingsFromTaskSelfTest extends GridCommonAbstrac private volatile int taskNum = -1; /** {@inheritDoc} */ - @Override protected Collection<? extends ComputeJob> split(int gridSize, Serializable arg) throws IgniteCheckedException { + @Override protected Collection<? extends ComputeJob> split(int gridSize, Serializable arg) throws IgniteException { if (log.isInfoEnabled()) log.info("Splitting job [job=" + this + ", gridSize=" + gridSize + ", arg=" + arg + ']'); @@ -259,7 +259,7 @@ public class GridSessionCancelSiblingsFromTaskSelfTest extends GridCommonAbstrac /** {@inheritDoc} */ @SuppressWarnings("deprecation") @Override public ComputeJobResultPolicy result(ComputeJobResult result, List<ComputeJobResult> received) - throws IgniteCheckedException { + throws IgniteException { if (received.size() == 1) { Collection<ComputeJobSibling> jobSiblings = taskSes.getJobSiblings(); @@ -278,7 +278,7 @@ public class GridSessionCancelSiblingsFromTaskSelfTest extends GridCommonAbstrac } /** {@inheritDoc} */ - @Override public String reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public String reduce(List<ComputeJobResult> results) throws IgniteException { if (log.isInfoEnabled()) log.info("Aggregating job [job=" + this + ", results=" + results + ']'); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/session/GridSessionCheckpointAbstractSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/session/GridSessionCheckpointAbstractSelfTest.java b/modules/core/src/test/java/org/gridgain/grid/session/GridSessionCheckpointAbstractSelfTest.java index f98e038..0917224 100644 --- a/modules/core/src/test/java/org/gridgain/grid/session/GridSessionCheckpointAbstractSelfTest.java +++ b/modules/core/src/test/java/org/gridgain/grid/session/GridSessionCheckpointAbstractSelfTest.java @@ -147,7 +147,7 @@ public abstract class GridSessionCheckpointAbstractSelfTest extends GridCommonAb private IgniteMarshaller marshaller; /** {@inheritDoc} */ - @Override protected Collection<ComputeJobAdapter> split(int gridSize, Object arg) throws IgniteCheckedException { + @Override protected Collection<ComputeJobAdapter> split(int gridSize, Object arg) throws IgniteException { for (int i = 0; i < SPLIT_COUNT; i++) { ses.saveCheckpoint("map:session:key:" + i, "map:session:testval:" + i); ses.saveCheckpoint("map:global:key:" + i, "map:global:testval:" + i, @@ -162,7 +162,7 @@ public abstract class GridSessionCheckpointAbstractSelfTest extends GridCommonAb private static final long serialVersionUID = -9118687978815477993L; /** {@inheritDoc} */ - @Override public Serializable execute() throws IgniteCheckedException { + @Override public Serializable execute() throws IgniteException { ses.saveCheckpoint("job:session:key:" + argument(0), "job:session:testval:" + argument(0)); ses.saveCheckpoint("job:global:key:" + argument(0), "job:global:testval:" + argument(0), ComputeTaskSessionScope.GLOBAL_SCOPE, 0); @@ -176,7 +176,7 @@ public abstract class GridSessionCheckpointAbstractSelfTest extends GridCommonAb } /** {@inheritDoc} */ - @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Object reduce(List<ComputeJobResult> results) throws IgniteException { int res = 0; for (ComputeJobResult result : results) { http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/session/GridSessionCollisionSpiSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/session/GridSessionCollisionSpiSelfTest.java b/modules/core/src/test/java/org/gridgain/grid/session/GridSessionCollisionSpiSelfTest.java index df5c765..b733979 100644 --- a/modules/core/src/test/java/org/gridgain/grid/session/GridSessionCollisionSpiSelfTest.java +++ b/modules/core/src/test/java/org/gridgain/grid/session/GridSessionCollisionSpiSelfTest.java @@ -60,7 +60,7 @@ public class GridSessionCollisionSpiSelfTest extends GridCommonAbstractTest { @ComputeTaskSessionFullSupport private static class GridSessionTestTask extends ComputeTaskSplitAdapter<Object, Object> { /** {@inheritDoc} */ - @Override protected Collection<ComputeJobAdapter> split(int gridSize, Object arg) throws IgniteCheckedException { + @Override protected Collection<ComputeJobAdapter> split(int gridSize, Object arg) throws IgniteException { Collection<ComputeJobAdapter> jobs = new ArrayList<>(gridSize); for (int i = 0; i < gridSize; i++) { @@ -98,7 +98,7 @@ public class GridSessionCollisionSpiSelfTest extends GridCommonAbstractTest { } /** {@inheritDoc} */ - @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Object reduce(List<ComputeJobResult> results) throws IgniteException { // Nothing to reduce. return null; } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/session/GridSessionFutureWaitJobAttributeSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/session/GridSessionFutureWaitJobAttributeSelfTest.java b/modules/core/src/test/java/org/gridgain/grid/session/GridSessionFutureWaitJobAttributeSelfTest.java index 9860c30..0bdb982 100644 --- a/modules/core/src/test/java/org/gridgain/grid/session/GridSessionFutureWaitJobAttributeSelfTest.java +++ b/modules/core/src/test/java/org/gridgain/grid/session/GridSessionFutureWaitJobAttributeSelfTest.java @@ -166,7 +166,7 @@ public class GridSessionFutureWaitJobAttributeSelfTest extends GridCommonAbstrac private volatile int taskNum = -1; /** {@inheritDoc} */ - @Override protected Collection<? extends ComputeJob> split(int gridSize, Serializable arg) throws IgniteCheckedException { + @Override protected Collection<? extends ComputeJob> split(int gridSize, Serializable arg) throws IgniteException { if (log.isInfoEnabled()) log.info("Splitting job [task=" + this + ", gridSize=" + gridSize + ", arg=" + arg + ']'); @@ -180,7 +180,7 @@ public class GridSessionFutureWaitJobAttributeSelfTest extends GridCommonAbstrac for (int i = 1; i <= SPLIT_COUNT; i++) { jobs.add(new ComputeJobAdapter(i) { - @Override public Serializable execute() throws IgniteCheckedException { + @Override public Serializable execute() throws IgniteException { assert taskSes != null; if (log.isInfoEnabled()) { @@ -216,7 +216,7 @@ public class GridSessionFutureWaitJobAttributeSelfTest extends GridCommonAbstrac /** {@inheritDoc} */ @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> received) - throws IgniteCheckedException { + throws IgniteException { if (res.getException() != null) throw res.getException(); @@ -224,7 +224,7 @@ public class GridSessionFutureWaitJobAttributeSelfTest extends GridCommonAbstrac } /** {@inheritDoc} */ - @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteException { if (log.isInfoEnabled()) log.info("Reducing job [job=" + this + ", results=" + results + ']'); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/session/GridSessionFutureWaitTaskAttributeSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/session/GridSessionFutureWaitTaskAttributeSelfTest.java b/modules/core/src/test/java/org/gridgain/grid/session/GridSessionFutureWaitTaskAttributeSelfTest.java index a46e37b..f387db1 100644 --- a/modules/core/src/test/java/org/gridgain/grid/session/GridSessionFutureWaitTaskAttributeSelfTest.java +++ b/modules/core/src/test/java/org/gridgain/grid/session/GridSessionFutureWaitTaskAttributeSelfTest.java @@ -163,7 +163,7 @@ public class GridSessionFutureWaitTaskAttributeSelfTest extends GridCommonAbstra private volatile int taskNum = -1; /** {@inheritDoc} */ - @Override protected Collection<? extends ComputeJob> split(int gridSize, Serializable arg) throws IgniteCheckedException { + @Override protected Collection<? extends ComputeJob> split(int gridSize, Serializable arg) throws IgniteException { if (log.isInfoEnabled()) log.info("Splitting job [job=" + this + ", gridSize=" + gridSize + ", arg=" + arg + ']'); @@ -193,7 +193,7 @@ public class GridSessionFutureWaitTaskAttributeSelfTest extends GridCommonAbstra /** {@inheritDoc} */ @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> received) - throws IgniteCheckedException { + throws IgniteException { if (res.getException() != null) throw res.getException(); @@ -223,7 +223,7 @@ public class GridSessionFutureWaitTaskAttributeSelfTest extends GridCommonAbstra } /** {@inheritDoc} */ - @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteException { if (log.isInfoEnabled()) log.info("Reducing job [job=" + this + ", results=" + results + ']'); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/session/GridSessionJobFailoverSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/session/GridSessionJobFailoverSelfTest.java b/modules/core/src/test/java/org/gridgain/grid/session/GridSessionJobFailoverSelfTest.java index 2a0493f..db5d0de 100644 --- a/modules/core/src/test/java/org/gridgain/grid/session/GridSessionJobFailoverSelfTest.java +++ b/modules/core/src/test/java/org/gridgain/grid/session/GridSessionJobFailoverSelfTest.java @@ -77,7 +77,7 @@ public class GridSessionJobFailoverSelfTest extends GridCommonAbstractTest { private boolean jobFailed; /** {@inheritDoc} */ - @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, String arg) throws IgniteCheckedException { + @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, String arg) throws IgniteException { ses.setAttribute("fail", true); for (int i = 0; i < 10; i++) { @@ -90,7 +90,7 @@ public class GridSessionJobFailoverSelfTest extends GridCommonAbstractTest { @IgniteLocalNodeIdResource private UUID locNodeId; - @Override public Serializable execute() throws IgniteCheckedException { + @Override public Serializable execute() throws IgniteException { boolean fail; try { @@ -136,7 +136,7 @@ public class GridSessionJobFailoverSelfTest extends GridCommonAbstractTest { /** {@inheritDoc} */ @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> received) - throws IgniteCheckedException { + throws IgniteException { if (res.getException() != null) { assert !jobFailed; @@ -149,7 +149,7 @@ public class GridSessionJobFailoverSelfTest extends GridCommonAbstractTest { } /** {@inheritDoc} */ - @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Object reduce(List<ComputeJobResult> results) throws IgniteException { assert results.size() == 1; return results.get(0).getData(); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/session/GridSessionJobWaitTaskAttributeSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/session/GridSessionJobWaitTaskAttributeSelfTest.java b/modules/core/src/test/java/org/gridgain/grid/session/GridSessionJobWaitTaskAttributeSelfTest.java index 729f7ef..66ae464 100644 --- a/modules/core/src/test/java/org/gridgain/grid/session/GridSessionJobWaitTaskAttributeSelfTest.java +++ b/modules/core/src/test/java/org/gridgain/grid/session/GridSessionJobWaitTaskAttributeSelfTest.java @@ -130,7 +130,7 @@ public class GridSessionJobWaitTaskAttributeSelfTest extends GridCommonAbstractT private ComputeTaskSession taskSes; /** {@inheritDoc} */ - @Override protected Collection<? extends ComputeJob> split(int gridSize, Serializable arg) throws IgniteCheckedException { + @Override protected Collection<? extends ComputeJob> split(int gridSize, Serializable arg) throws IgniteException { assert taskSes != null; if (log.isInfoEnabled()) @@ -140,7 +140,7 @@ public class GridSessionJobWaitTaskAttributeSelfTest extends GridCommonAbstractT for (int i = 1; i <= SPLIT_COUNT; i++) { jobs.add(new ComputeJobAdapter(i) { - @Override public Serializable execute() throws IgniteCheckedException { + @Override public Serializable execute() throws IgniteException { assert taskSes != null; if (log.isInfoEnabled()) @@ -173,7 +173,7 @@ public class GridSessionJobWaitTaskAttributeSelfTest extends GridCommonAbstractT /** {@inheritDoc} */ @Override public ComputeJobResultPolicy result(ComputeJobResult result, List<ComputeJobResult> received) - throws IgniteCheckedException { + throws IgniteException { if (result.getException() != null) throw result.getException(); @@ -189,7 +189,7 @@ public class GridSessionJobWaitTaskAttributeSelfTest extends GridCommonAbstractT } /** {@inheritDoc} */ - @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteException { if (log.isInfoEnabled()) log.info("Reducing job [job=" + this + ", results=" + results + ']'); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/session/GridSessionLoadSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/session/GridSessionLoadSelfTest.java b/modules/core/src/test/java/org/gridgain/grid/session/GridSessionLoadSelfTest.java index 3bff818..fdfe2bb 100644 --- a/modules/core/src/test/java/org/gridgain/grid/session/GridSessionLoadSelfTest.java +++ b/modules/core/src/test/java/org/gridgain/grid/session/GridSessionLoadSelfTest.java @@ -127,7 +127,7 @@ public class GridSessionLoadSelfTest extends GridCommonAbstractTest { /** {@inheritDoc} */ @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, Integer arg) - throws IgniteCheckedException { + throws IgniteException { assert taskSes != null; assert arg != null; assert arg > 1; @@ -163,7 +163,7 @@ public class GridSessionLoadSelfTest extends GridCommonAbstractTest { } /** {@inheritDoc} */ - @Override public Boolean reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Boolean reduce(List<ComputeJobResult> results) throws IgniteException { assert taskSes != null; assert results != null; assert params != null; @@ -228,7 +228,7 @@ public class GridSessionLoadSelfTest extends GridCommonAbstractTest { } /** {@inheritDoc} */ - @Override public Serializable execute() throws IgniteCheckedException { + @Override public Serializable execute() throws IgniteException { assert taskSes != null; assert argument(0) != null; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/session/GridSessionSetFutureAttributeSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/session/GridSessionSetFutureAttributeSelfTest.java b/modules/core/src/test/java/org/gridgain/grid/session/GridSessionSetFutureAttributeSelfTest.java index 27906d0..ef9cc5e 100644 --- a/modules/core/src/test/java/org/gridgain/grid/session/GridSessionSetFutureAttributeSelfTest.java +++ b/modules/core/src/test/java/org/gridgain/grid/session/GridSessionSetFutureAttributeSelfTest.java @@ -170,7 +170,7 @@ public class GridSessionSetFutureAttributeSelfTest extends GridCommonAbstractTes private volatile int taskNum = -1; /** {@inheritDoc} */ - @Override protected Collection<? extends ComputeJob> split(int gridSize, Serializable arg) throws IgniteCheckedException { + @Override protected Collection<? extends ComputeJob> split(int gridSize, Serializable arg) throws IgniteException { if (log.isInfoEnabled()) log.info("Splitting job [task=" + this + ", gridSize=" + gridSize + ", arg=" + arg + ']'); @@ -185,7 +185,7 @@ public class GridSessionSetFutureAttributeSelfTest extends GridCommonAbstractTes for (int i = 1; i <= SPLIT_COUNT; i++) { jobs.add(new ComputeJobAdapter(i) { /** {@inheritDoc} */ - @Override public Serializable execute() throws IgniteCheckedException { + @Override public Serializable execute() throws IgniteException { assert taskSes != null; if (log.isInfoEnabled()) @@ -219,7 +219,7 @@ public class GridSessionSetFutureAttributeSelfTest extends GridCommonAbstractTes /** {@inheritDoc} */ @Override public ComputeJobResultPolicy result(ComputeJobResult result, List<ComputeJobResult> received) - throws IgniteCheckedException { + throws IgniteException { if (result.getException() != null) throw result.getException(); @@ -227,7 +227,7 @@ public class GridSessionSetFutureAttributeSelfTest extends GridCommonAbstractTes } /** {@inheritDoc} */ - @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteException { if (log.isInfoEnabled()) log.info("Reducing job [job=" + this + ", results=" + results + ']'); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/session/GridSessionSetFutureAttributeWaitListenerSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/session/GridSessionSetFutureAttributeWaitListenerSelfTest.java b/modules/core/src/test/java/org/gridgain/grid/session/GridSessionSetFutureAttributeWaitListenerSelfTest.java index 9c780fb..b5d50d5 100644 --- a/modules/core/src/test/java/org/gridgain/grid/session/GridSessionSetFutureAttributeWaitListenerSelfTest.java +++ b/modules/core/src/test/java/org/gridgain/grid/session/GridSessionSetFutureAttributeWaitListenerSelfTest.java @@ -132,7 +132,7 @@ public class GridSessionSetFutureAttributeWaitListenerSelfTest extends GridCommo private ComputeTaskSession taskSes; /** {@inheritDoc} */ - @Override protected Collection<? extends ComputeJob> split(int gridSize, Serializable arg) throws IgniteCheckedException { + @Override protected Collection<? extends ComputeJob> split(int gridSize, Serializable arg) throws IgniteException { if (log.isInfoEnabled()) log.info("Splitting job [job=" + this + ", gridSize=" + gridSize + ", arg=" + arg + ']'); @@ -141,7 +141,7 @@ public class GridSessionSetFutureAttributeWaitListenerSelfTest extends GridCommo for (int i = 1; i <= SPLIT_COUNT; i++) { jobs.add(new ComputeJobAdapter(i) { @SuppressWarnings({"UnconditionalWait"}) - public Serializable execute() throws IgniteCheckedException { + public Serializable execute() throws IgniteException { assert taskSes != null; if (log.isInfoEnabled()) @@ -171,7 +171,7 @@ public class GridSessionSetFutureAttributeWaitListenerSelfTest extends GridCommo /** {@inheritDoc} */ @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> received) - throws IgniteCheckedException { + throws IgniteException { if (res.getException() != null) throw res.getException(); @@ -179,7 +179,7 @@ public class GridSessionSetFutureAttributeWaitListenerSelfTest extends GridCommo } /** {@inheritDoc} */ - @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteException { if (log.isInfoEnabled()) log.info("Reducing job [job=" + this + ", results=" + results + ']'); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/session/GridSessionSetJobAttribute2SelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/session/GridSessionSetJobAttribute2SelfTest.java b/modules/core/src/test/java/org/gridgain/grid/session/GridSessionSetJobAttribute2SelfTest.java index db09475..dee2348 100644 --- a/modules/core/src/test/java/org/gridgain/grid/session/GridSessionSetJobAttribute2SelfTest.java +++ b/modules/core/src/test/java/org/gridgain/grid/session/GridSessionSetJobAttribute2SelfTest.java @@ -66,7 +66,7 @@ public class GridSessionSetJobAttribute2SelfTest extends GridCommonAbstractTest private UUID attrVal; /** {@inheritDoc} */ - @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, UUID arg) throws IgniteCheckedException { + @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, UUID arg) throws IgniteException { assert subgrid.size() == 2; assert arg != null; @@ -83,7 +83,7 @@ public class GridSessionSetJobAttribute2SelfTest extends GridCommonAbstractTest } /** {@inheritDoc} */ - @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Object reduce(List<ComputeJobResult> results) throws IgniteException { try { Thread.sleep(100); } @@ -115,7 +115,7 @@ public class GridSessionSetJobAttribute2SelfTest extends GridCommonAbstractTest } /** {@inheritDoc} */ - @Override public Serializable execute() throws IgniteCheckedException { + @Override public Serializable execute() throws IgniteException { assert taskSes != null; assert argument(0) != null; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/session/GridSessionSetJobAttributeOrderSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/session/GridSessionSetJobAttributeOrderSelfTest.java b/modules/core/src/test/java/org/gridgain/grid/session/GridSessionSetJobAttributeOrderSelfTest.java index e84d8f3..e7a787e 100644 --- a/modules/core/src/test/java/org/gridgain/grid/session/GridSessionSetJobAttributeOrderSelfTest.java +++ b/modules/core/src/test/java/org/gridgain/grid/session/GridSessionSetJobAttributeOrderSelfTest.java @@ -78,7 +78,7 @@ public class GridSessionSetJobAttributeOrderSelfTest extends GridCommonAbstractT private IgniteLogger log; /** {@inheritDoc} */ - @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, UUID arg) throws IgniteCheckedException { + @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, UUID arg) throws IgniteException { assert subgrid.size() == 2; assert arg != null; @@ -93,7 +93,7 @@ public class GridSessionSetJobAttributeOrderSelfTest extends GridCommonAbstractT } /** {@inheritDoc} */ - @Override public Serializable reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Serializable reduce(List<ComputeJobResult> results) throws IgniteException { try { if (taskSes.waitForAttribute(TEST_ATTR_KEY, SETS_ATTR_COUNT, 20000)) { log.info("Successfully waited for attribute [key=" + TEST_ATTR_KEY + @@ -119,7 +119,7 @@ public class GridSessionSetJobAttributeOrderSelfTest extends GridCommonAbstractT private IgniteLogger log; /** {@inheritDoc} */ - @Override public Serializable execute() throws IgniteCheckedException { + @Override public Serializable execute() throws IgniteException { assert taskSes != null; try { http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/session/GridSessionSetJobAttributeSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/session/GridSessionSetJobAttributeSelfTest.java b/modules/core/src/test/java/org/gridgain/grid/session/GridSessionSetJobAttributeSelfTest.java index 165cc9d..fe98080 100644 --- a/modules/core/src/test/java/org/gridgain/grid/session/GridSessionSetJobAttributeSelfTest.java +++ b/modules/core/src/test/java/org/gridgain/grid/session/GridSessionSetJobAttributeSelfTest.java @@ -127,7 +127,7 @@ public class GridSessionSetJobAttributeSelfTest extends GridCommonAbstractTest { private ComputeTaskSession taskSes; /** {@inheritDoc} */ - @Override protected Collection<? extends ComputeJob> split(int gridSize, Serializable arg) throws IgniteCheckedException { + @Override protected Collection<? extends ComputeJob> split(int gridSize, Serializable arg) throws IgniteException { if (log.isInfoEnabled()) log.info("Splitting job [job=" + this + ", gridSize=" + gridSize + ", arg=" + arg + ']'); @@ -135,7 +135,7 @@ public class GridSessionSetJobAttributeSelfTest extends GridCommonAbstractTest { for (int i = 1; i <= SPLIT_COUNT; i++) { jobs.add(new ComputeJobAdapter(i) { - @Override public Serializable execute() throws IgniteCheckedException { + @Override public Serializable execute() throws IgniteException { assert taskSes != null; int arg = this.<Integer>argument(0); @@ -174,7 +174,7 @@ public class GridSessionSetJobAttributeSelfTest extends GridCommonAbstractTest { /** {@inheritDoc} */ @Override public ComputeJobResultPolicy result(ComputeJobResult result, List<ComputeJobResult> received) - throws IgniteCheckedException { + throws IgniteException { if (result.getException() != null) throw result.getException(); @@ -182,7 +182,7 @@ public class GridSessionSetJobAttributeSelfTest extends GridCommonAbstractTest { } /** {@inheritDoc} */ - @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteException { if (log.isInfoEnabled()) log.info("Reducing job [job=" + this + ", results=" + results + ']'); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/session/GridSessionSetJobAttributeWaitListenerSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/session/GridSessionSetJobAttributeWaitListenerSelfTest.java b/modules/core/src/test/java/org/gridgain/grid/session/GridSessionSetJobAttributeWaitListenerSelfTest.java index 7a9fe4b..8dddb15 100644 --- a/modules/core/src/test/java/org/gridgain/grid/session/GridSessionSetJobAttributeWaitListenerSelfTest.java +++ b/modules/core/src/test/java/org/gridgain/grid/session/GridSessionSetJobAttributeWaitListenerSelfTest.java @@ -120,7 +120,7 @@ public class GridSessionSetJobAttributeWaitListenerSelfTest extends GridCommonAb private ComputeTaskSession taskSes; /** {@inheritDoc} */ - @Override protected Collection<? extends ComputeJob> split(int gridSize, Serializable arg) throws IgniteCheckedException { + @Override protected Collection<? extends ComputeJob> split(int gridSize, Serializable arg) throws IgniteException { if (log.isInfoEnabled()) log.info("Splitting job [job=" + this + ", gridSize=" + gridSize + ", arg=" + arg + ']'); @@ -129,7 +129,7 @@ public class GridSessionSetJobAttributeWaitListenerSelfTest extends GridCommonAb for (int i = 1; i <= SPLIT_COUNT; i++) { jobs.add(new ComputeJobAdapter(i) { @SuppressWarnings({"UnconditionalWait"}) - public Serializable execute() throws IgniteCheckedException { + public Serializable execute() throws IgniteException { assert taskSes != null; if (log.isInfoEnabled()) @@ -168,7 +168,7 @@ public class GridSessionSetJobAttributeWaitListenerSelfTest extends GridCommonAb } /** {@inheritDoc} */ - @Override public ComputeJobResultPolicy result(ComputeJobResult result, List<ComputeJobResult> received) throws IgniteCheckedException { + @Override public ComputeJobResultPolicy result(ComputeJobResult result, List<ComputeJobResult> received) throws IgniteException { if (result.getException() != null) throw result.getException(); @@ -176,7 +176,7 @@ public class GridSessionSetJobAttributeWaitListenerSelfTest extends GridCommonAb } /** {@inheritDoc} */ - @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteException { if (log.isInfoEnabled()) log.info("Reducing job [job=" + this + ", results=" + results + ']'); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/session/GridSessionSetTaskAttributeSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/session/GridSessionSetTaskAttributeSelfTest.java b/modules/core/src/test/java/org/gridgain/grid/session/GridSessionSetTaskAttributeSelfTest.java index 56c9328..3985380 100644 --- a/modules/core/src/test/java/org/gridgain/grid/session/GridSessionSetTaskAttributeSelfTest.java +++ b/modules/core/src/test/java/org/gridgain/grid/session/GridSessionSetTaskAttributeSelfTest.java @@ -113,7 +113,7 @@ public class GridSessionSetTaskAttributeSelfTest extends GridCommonAbstractTest private ComputeTaskSession taskSes; /** {@inheritDoc} */ - @Override protected Collection<? extends ComputeJob> split(int gridSize, Serializable arg) throws IgniteCheckedException { + @Override protected Collection<? extends ComputeJob> split(int gridSize, Serializable arg) throws IgniteException { assert taskSes != null; if (log.isInfoEnabled()) @@ -123,7 +123,7 @@ public class GridSessionSetTaskAttributeSelfTest extends GridCommonAbstractTest for (int i = 1; i <= SPLIT_COUNT; i++) { jobs.add(new ComputeJobAdapter(i) { - @Override public Serializable execute() throws IgniteCheckedException { + @Override public Serializable execute() throws IgniteException { assert taskSes != null; if (log.isInfoEnabled()) @@ -157,7 +157,7 @@ public class GridSessionSetTaskAttributeSelfTest extends GridCommonAbstractTest /** {@inheritDoc} */ @Override public ComputeJobResultPolicy result(ComputeJobResult result, List<ComputeJobResult> received) - throws IgniteCheckedException { + throws IgniteException { if (result.getException() != null) throw result.getException(); @@ -170,7 +170,7 @@ public class GridSessionSetTaskAttributeSelfTest extends GridCommonAbstractTest } /** {@inheritDoc} */ - @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteException { if (log.isInfoEnabled()) log.info("Reducing job [job=" + this + ", results=" + results + ']'); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/session/GridSessionTaskWaitJobAttributeSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/session/GridSessionTaskWaitJobAttributeSelfTest.java b/modules/core/src/test/java/org/gridgain/grid/session/GridSessionTaskWaitJobAttributeSelfTest.java index b97d2f6..c3dde84 100644 --- a/modules/core/src/test/java/org/gridgain/grid/session/GridSessionTaskWaitJobAttributeSelfTest.java +++ b/modules/core/src/test/java/org/gridgain/grid/session/GridSessionTaskWaitJobAttributeSelfTest.java @@ -113,7 +113,7 @@ public class GridSessionTaskWaitJobAttributeSelfTest extends GridCommonAbstractT private ComputeTaskSession taskSes; /** {@inheritDoc} */ - @Override protected Collection<? extends ComputeJob> split(int gridSize, Serializable arg) throws IgniteCheckedException { + @Override protected Collection<? extends ComputeJob> split(int gridSize, Serializable arg) throws IgniteException { if (log.isInfoEnabled()) log.info("Splitting job [job=" + this + ", gridSize=" + gridSize + ", arg=" + arg + ']'); @@ -121,7 +121,7 @@ public class GridSessionTaskWaitJobAttributeSelfTest extends GridCommonAbstractT for (int i = 1; i <= SPLIT_COUNT; i++) { jobs.add(new ComputeJobAdapter(i) { - @Override public Object execute() throws IgniteCheckedException { + @Override public Object execute() throws IgniteException { assert taskSes != null; if (log.isInfoEnabled()) { @@ -143,7 +143,7 @@ public class GridSessionTaskWaitJobAttributeSelfTest extends GridCommonAbstractT /** {@inheritDoc} */ @Override public ComputeJobResultPolicy result(ComputeJobResult result, List<ComputeJobResult> received) - throws IgniteCheckedException { + throws IgniteException { if (result.getException() != null) throw result.getException(); @@ -163,7 +163,7 @@ public class GridSessionTaskWaitJobAttributeSelfTest extends GridCommonAbstractT } /** {@inheritDoc} */ - @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteException { if (log.isInfoEnabled()) log.info("Reducing job [job=" + this + ", results=" + results + ']'); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/session/GridSessionWaitAttributeSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/session/GridSessionWaitAttributeSelfTest.java b/modules/core/src/test/java/org/gridgain/grid/session/GridSessionWaitAttributeSelfTest.java index e03e4b0..b43555b 100644 --- a/modules/core/src/test/java/org/gridgain/grid/session/GridSessionWaitAttributeSelfTest.java +++ b/modules/core/src/test/java/org/gridgain/grid/session/GridSessionWaitAttributeSelfTest.java @@ -393,7 +393,7 @@ public class GridSessionWaitAttributeSelfTest extends GridCommonAbstractTest { @ComputeTaskSessionFullSupport public static class TestSessionTask extends ComputeTaskSplitAdapter<WaitAttributeType, Object> { /** {@inheritDoc} */ - @Override protected Collection<TestSessionJob> split(int gridSize, WaitAttributeType type) throws IgniteCheckedException { + @Override protected Collection<TestSessionJob> split(int gridSize, WaitAttributeType type) throws IgniteException { assert type != null; Collection<TestSessionJob> jobs = new ArrayList<>(JOB_NUM); @@ -405,7 +405,7 @@ public class GridSessionWaitAttributeSelfTest extends GridCommonAbstractTest { } /** {@inheritDoc} */ - @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Object reduce(List<ComputeJobResult> results) throws IgniteException { return null; } } @@ -432,7 +432,7 @@ public class GridSessionWaitAttributeSelfTest extends GridCommonAbstractTest { } /** {@inheritDoc} */ - @Override public Serializable execute() throws IgniteCheckedException { + @Override public Serializable execute() throws IgniteException { WaitAttributeType m = argument(0); checkSessionAttributes(taskSes, "fut", m); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/grid/util/offheap/GridOffHeapMapAbstractSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/grid/util/offheap/GridOffHeapMapAbstractSelfTest.java b/modules/core/src/test/java/org/gridgain/grid/util/offheap/GridOffHeapMapAbstractSelfTest.java index 1833414..65b287e 100644 --- a/modules/core/src/test/java/org/gridgain/grid/util/offheap/GridOffHeapMapAbstractSelfTest.java +++ b/modules/core/src/test/java/org/gridgain/grid/util/offheap/GridOffHeapMapAbstractSelfTest.java @@ -740,7 +740,7 @@ public abstract class GridOffHeapMapAbstractSelfTest extends GridCommonAbstractT IgniteFuture<?> fut = multithreadedAsync(new Callable<Void>() { @Override - public Void call() throws IgniteCheckedException { + public Void call() throws IgniteException { Random rnd = new Random(); while (!stop.get()) { http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/loadtests/GridCacheLoadPopulationTask.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/loadtests/GridCacheLoadPopulationTask.java b/modules/core/src/test/java/org/gridgain/loadtests/GridCacheLoadPopulationTask.java index 36ea22b..aabc565 100644 --- a/modules/core/src/test/java/org/gridgain/loadtests/GridCacheLoadPopulationTask.java +++ b/modules/core/src/test/java/org/gridgain/loadtests/GridCacheLoadPopulationTask.java @@ -25,12 +25,12 @@ public class GridCacheLoadPopulationTask extends ComputeTaskSplitAdapter<Void, V private static final long serialVersionUID = 1L; /** {@inheritDoc} */ - @Override public Void reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Void reduce(List<ComputeJobResult> results) throws IgniteException { return null; } /** {@inheritDoc} */ - @Override protected Collection<? extends ComputeJob> split(int gridSize, Void arg) throws IgniteCheckedException { + @Override protected Collection<? extends ComputeJob> split(int gridSize, Void arg) throws IgniteException { Collection<ChunkPopulationJob> jobs = new ArrayList<>(); int maxElements = 10000; @@ -75,7 +75,7 @@ public class GridCacheLoadPopulationTask extends ComputeTaskSplitAdapter<Void, V /** {@inheritDoc} */ @SuppressWarnings({"unchecked", "ConstantConditions"}) - @Override public Object execute() throws IgniteCheckedException { + @Override public Object execute() throws IgniteException { Map<Object, TestValue> map = new TreeMap<>(); for (int i = startElementIdx; i < startElementIdx + maxElements; i++) {
