http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/loadtests/colocation/GridTestLifecycleBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/loadtests/colocation/GridTestLifecycleBean.java b/modules/core/src/test/java/org/gridgain/loadtests/colocation/GridTestLifecycleBean.java index 6c39289..6e7bcc6 100644 --- a/modules/core/src/test/java/org/gridgain/loadtests/colocation/GridTestLifecycleBean.java +++ b/modules/core/src/test/java/org/gridgain/loadtests/colocation/GridTestLifecycleBean.java @@ -22,7 +22,7 @@ public class GridTestLifecycleBean implements LifecycleBean { @IgniteInstanceResource private Ignite g; - @Override public void onLifecycleEvent(LifecycleEventType type) throws IgniteCheckedException { + @Override public void onLifecycleEvent(LifecycleEventType type) throws IgniteException { if (type == LifecycleEventType.AFTER_GRID_START) { GridCache<GridTestKey, Long> cache = g.cache("partitioned");
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/loadtests/direct/multisplit/GridLoadTestJob.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/loadtests/direct/multisplit/GridLoadTestJob.java b/modules/core/src/test/java/org/gridgain/loadtests/direct/multisplit/GridLoadTestJob.java index a29c0a2..ba07de8 100644 --- a/modules/core/src/test/java/org/gridgain/loadtests/direct/multisplit/GridLoadTestJob.java +++ b/modules/core/src/test/java/org/gridgain/loadtests/direct/multisplit/GridLoadTestJob.java @@ -34,7 +34,7 @@ public class GridLoadTestJob extends ComputeJobAdapter { /** {@inheritDoc} */ @SuppressWarnings("unchecked") - @Override public Serializable execute() throws IgniteCheckedException { + @Override public Serializable execute() throws IgniteException { Integer i = this.<Integer>argument(0); assert i != null && i > 0; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/loadtests/direct/multisplit/GridLoadTestTask.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/loadtests/direct/multisplit/GridLoadTestTask.java b/modules/core/src/test/java/org/gridgain/loadtests/direct/multisplit/GridLoadTestTask.java index cade932..93c99c2 100644 --- a/modules/core/src/test/java/org/gridgain/loadtests/direct/multisplit/GridLoadTestTask.java +++ b/modules/core/src/test/java/org/gridgain/loadtests/direct/multisplit/GridLoadTestTask.java @@ -31,7 +31,7 @@ public class GridLoadTestTask extends ComputeTaskAdapter<Integer, Integer> { private Ignite ignite; /** {@inheritDoc} */ - @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, Integer arg) throws IgniteCheckedException { + @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, Integer arg) throws IgniteException { assert arg != null; assert arg > 1; @@ -59,7 +59,7 @@ public class GridLoadTestTask extends ComputeTaskAdapter<Integer, Integer> { } /** {@inheritDoc} */ - @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteException { assert results != null; int retVal = 0; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/loadtests/direct/newnodes/GridSingleSplitNewNodesTestTask.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/loadtests/direct/newnodes/GridSingleSplitNewNodesTestTask.java b/modules/core/src/test/java/org/gridgain/loadtests/direct/newnodes/GridSingleSplitNewNodesTestTask.java index 570f59f..83c0d72 100644 --- a/modules/core/src/test/java/org/gridgain/loadtests/direct/newnodes/GridSingleSplitNewNodesTestTask.java +++ b/modules/core/src/test/java/org/gridgain/loadtests/direct/newnodes/GridSingleSplitNewNodesTestTask.java @@ -30,7 +30,7 @@ public class GridSingleSplitNewNodesTestTask extends ComputeTaskAdapter<Integer, private ComputeLoadBalancer balancer; /** {@inheritDoc} */ - @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, Integer arg) throws IgniteCheckedException { + @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, Integer arg) throws IgniteException { assert !subgrid.isEmpty() : "Subgrid cannot be empty."; Map<ComputeJobAdapter, ClusterNode> jobs = new HashMap<>(subgrid.size()); @@ -47,7 +47,7 @@ public class GridSingleSplitNewNodesTestTask extends ComputeTaskAdapter<Integer, private ComputeTaskSession jobSes; /** {@inheritDoc} */ - @Override public Serializable execute() throws IgniteCheckedException { + @Override public Serializable execute() throws IgniteException { assert jobSes != null; Integer arg = this.<Integer>argument(0); @@ -73,7 +73,7 @@ public class GridSingleSplitNewNodesTestTask extends ComputeTaskAdapter<Integer, } /** {@inheritDoc} */ - @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteException { int retVal = 0; for (ComputeJobResult res : results) { http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/loadtests/direct/session/GridSessionLoadTestJob.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/loadtests/direct/session/GridSessionLoadTestJob.java b/modules/core/src/test/java/org/gridgain/loadtests/direct/session/GridSessionLoadTestJob.java index 7ac5546..4cf62bd 100644 --- a/modules/core/src/test/java/org/gridgain/loadtests/direct/session/GridSessionLoadTestJob.java +++ b/modules/core/src/test/java/org/gridgain/loadtests/direct/session/GridSessionLoadTestJob.java @@ -41,7 +41,7 @@ public class GridSessionLoadTestJob extends ComputeJobAdapter { } /** {@inheritDoc} */ - @Override public Serializable execute() throws IgniteCheckedException { + @Override public Serializable execute() throws IgniteException { assert taskSes != null; Object arg = argument(0); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/loadtests/direct/session/GridSessionLoadTestTask.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/loadtests/direct/session/GridSessionLoadTestTask.java b/modules/core/src/test/java/org/gridgain/loadtests/direct/session/GridSessionLoadTestTask.java index e43e088..b2d8a62 100644 --- a/modules/core/src/test/java/org/gridgain/loadtests/direct/session/GridSessionLoadTestTask.java +++ b/modules/core/src/test/java/org/gridgain/loadtests/direct/session/GridSessionLoadTestTask.java @@ -33,7 +33,7 @@ public class GridSessionLoadTestTask extends ComputeTaskAdapter<Integer, Boolean private Map<String, Integer> params; /** {@inheritDoc} */ - @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, Integer arg) throws IgniteCheckedException { + @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, Integer arg) throws IgniteException { assert taskSes != null; assert arg != null; assert arg > 0; @@ -78,7 +78,7 @@ public class GridSessionLoadTestTask extends ComputeTaskAdapter<Integer, Boolean /** {@inheritDoc} */ @SuppressWarnings("BusyWait") - @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; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/loadtests/direct/stealing/GridStealingLoadTestJob.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/loadtests/direct/stealing/GridStealingLoadTestJob.java b/modules/core/src/test/java/org/gridgain/loadtests/direct/stealing/GridStealingLoadTestJob.java index 116dada..14e402e 100644 --- a/modules/core/src/test/java/org/gridgain/loadtests/direct/stealing/GridStealingLoadTestJob.java +++ b/modules/core/src/test/java/org/gridgain/loadtests/direct/stealing/GridStealingLoadTestJob.java @@ -34,7 +34,7 @@ public class GridStealingLoadTestJob extends ComputeJobAdapter { private ComputeJobContext ctx; /** {@inheritDoc} */ - @Override public Serializable execute() throws IgniteCheckedException { + @Override public Serializable execute() throws IgniteException { if (log.isDebugEnabled()) log.debug("Executing job on node [nodeId=" + nodeId + ", jobId=" + ctx.getJobId() + ']'); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/loadtests/direct/stealing/GridStealingLoadTestTask.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/loadtests/direct/stealing/GridStealingLoadTestTask.java b/modules/core/src/test/java/org/gridgain/loadtests/direct/stealing/GridStealingLoadTestTask.java index ca5516e..cf8f1d8 100644 --- a/modules/core/src/test/java/org/gridgain/loadtests/direct/stealing/GridStealingLoadTestTask.java +++ b/modules/core/src/test/java/org/gridgain/loadtests/direct/stealing/GridStealingLoadTestTask.java @@ -31,7 +31,7 @@ public class GridStealingLoadTestTask extends ComputeTaskAdapter<UUID, Integer> private int stolenJobs; /** {@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 arg != null; assert subgrid.size() > 1: "Test requires at least 2 nodes. One with load and another one to steal."; @@ -75,7 +75,7 @@ public class GridStealingLoadTestTask extends ComputeTaskAdapter<UUID, Integer> } /** {@inheritDoc} */ - @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteException { assert results != null; for (ComputeJobResult res : results) { http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/loadtests/dsi/GridDsiLifecycleBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/loadtests/dsi/GridDsiLifecycleBean.java b/modules/core/src/test/java/org/gridgain/loadtests/dsi/GridDsiLifecycleBean.java index 6a5dae7..e12cde9 100644 --- a/modules/core/src/test/java/org/gridgain/loadtests/dsi/GridDsiLifecycleBean.java +++ b/modules/core/src/test/java/org/gridgain/loadtests/dsi/GridDsiLifecycleBean.java @@ -32,7 +32,7 @@ public class GridDsiLifecycleBean implements LifecycleBean { private ApplicationContext springCtx; /** {@inheritDoc} */ - @Override public void onLifecycleEvent(LifecycleEventType evt) throws IgniteCheckedException { + @Override public void onLifecycleEvent(LifecycleEventType evt) throws IgniteException { switch (evt) { case BEFORE_GRID_START: break; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/loadtests/dsi/GridDsiRequestTask.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/loadtests/dsi/GridDsiRequestTask.java b/modules/core/src/test/java/org/gridgain/loadtests/dsi/GridDsiRequestTask.java index a285319..d8cdef4 100644 --- a/modules/core/src/test/java/org/gridgain/loadtests/dsi/GridDsiRequestTask.java +++ b/modules/core/src/test/java/org/gridgain/loadtests/dsi/GridDsiRequestTask.java @@ -20,12 +20,12 @@ import java.util.*; */ public class GridDsiRequestTask extends ComputeTaskSplitAdapter<GridDsiMessage, T3<Long, Integer, Integer>> { /** {@inheritDoc} */ - @Override protected Collection<? extends ComputeJob> split(int arg0, GridDsiMessage msg) throws IgniteCheckedException { + @Override protected Collection<? extends ComputeJob> split(int arg0, GridDsiMessage msg) throws IgniteException { return Collections.singletonList(new GridDsiPerfJob(msg)); } /** {@inheritDoc} */ - @Override public T3<Long, Integer, Integer> reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public T3<Long, Integer, Integer> 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/loadtests/dsi/GridDsiResponseTask.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/loadtests/dsi/GridDsiResponseTask.java b/modules/core/src/test/java/org/gridgain/loadtests/dsi/GridDsiResponseTask.java index 08e01be..621a655 100644 --- a/modules/core/src/test/java/org/gridgain/loadtests/dsi/GridDsiResponseTask.java +++ b/modules/core/src/test/java/org/gridgain/loadtests/dsi/GridDsiResponseTask.java @@ -20,12 +20,12 @@ import java.util.*; */ public class GridDsiResponseTask extends ComputeTaskSplitAdapter<GridDsiMessage, T3<Long, Integer, Integer>> { /** {@inheritDoc} */ - @Override protected Collection<? extends ComputeJob> split(int arg0, GridDsiMessage msg) throws IgniteCheckedException { + @Override protected Collection<? extends ComputeJob> split(int arg0, GridDsiMessage msg) throws IgniteException { return Collections.singletonList(new GridDsiPerfJob(msg)); } /** {@inheritDoc} */ - @Override public T3<Long, Integer, Integer> reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public T3<Long, Integer, Integer> 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/loadtests/job/GridJobExecutionLoadTestJob.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/loadtests/job/GridJobExecutionLoadTestJob.java b/modules/core/src/test/java/org/gridgain/loadtests/job/GridJobExecutionLoadTestJob.java index 0ae5d09..33838df 100644 --- a/modules/core/src/test/java/org/gridgain/loadtests/job/GridJobExecutionLoadTestJob.java +++ b/modules/core/src/test/java/org/gridgain/loadtests/job/GridJobExecutionLoadTestJob.java @@ -19,7 +19,7 @@ import java.io.*; */ public class GridJobExecutionLoadTestJob implements ComputeJob, Externalizable { /** {@inheritDoc} */ - @Override public Object execute() throws IgniteCheckedException { + @Override public Object execute() throws IgniteException { return null; } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/loadtests/job/GridJobExecutionLoadTestTask.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/loadtests/job/GridJobExecutionLoadTestTask.java b/modules/core/src/test/java/org/gridgain/loadtests/job/GridJobExecutionLoadTestTask.java index 396f86c..1cf6fd1 100644 --- a/modules/core/src/test/java/org/gridgain/loadtests/job/GridJobExecutionLoadTestTask.java +++ b/modules/core/src/test/java/org/gridgain/loadtests/job/GridJobExecutionLoadTestTask.java @@ -25,17 +25,17 @@ import static org.apache.ignite.compute.ComputeJobResultPolicy.*; public class GridJobExecutionLoadTestTask implements ComputeTask<Object, Object> { /** {@inheritDoc} */ @Nullable @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, @Nullable Object arg) - throws IgniteCheckedException { + throws IgniteException { return F.asMap(new GridJobExecutionLoadTestJob(), subgrid.get(0)); } /** {@inheritDoc} */ - @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) throws IgniteCheckedException { + @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) throws IgniteException { return REDUCE; } /** {@inheritDoc} */ - @Nullable @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Nullable @Override public Object reduce(List<ComputeJobResult> results) throws IgniteException { return null; } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/loadtests/job/GridJobExecutionSingleNodeLoadTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/loadtests/job/GridJobExecutionSingleNodeLoadTest.java b/modules/core/src/test/java/org/gridgain/loadtests/job/GridJobExecutionSingleNodeLoadTest.java index de4f4b8..867af1f 100644 --- a/modules/core/src/test/java/org/gridgain/loadtests/job/GridJobExecutionSingleNodeLoadTest.java +++ b/modules/core/src/test/java/org/gridgain/loadtests/job/GridJobExecutionSingleNodeLoadTest.java @@ -73,7 +73,7 @@ public class GridJobExecutionSingleNodeLoadTest { X.println("Warming up..."); GridLoadTestUtils.runMultithreadedInLoop(new Callable<Object>() { - @Override public Object call() throws IgniteCheckedException { + @Override public Object call() throws IgniteException { g.compute().execute(GridJobExecutionLoadTestTask.class, null); return null; @@ -198,17 +198,17 @@ public class GridJobExecutionSingleNodeLoadTest { private static class GridJobExecutionLoadTestTask implements ComputeTask<Object, Object> { /** {@inheritDoc} */ @Nullable @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, @Nullable Object arg) - throws IgniteCheckedException { + throws IgniteException { return F.asMap(new GridJobExecutionLoadTestJob(), subgrid.get(0)); } /** {@inheritDoc} */ - @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) throws IgniteCheckedException { + @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) throws IgniteException { return REDUCE; } /** {@inheritDoc} */ - @Nullable @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Nullable @Override public Object reduce(List<ComputeJobResult> results) throws IgniteException { return null; } } @@ -218,7 +218,7 @@ public class GridJobExecutionSingleNodeLoadTest { */ private static class GridJobExecutionLoadTestJob implements ComputeJob { /** {@inheritDoc} */ - @Override public Object execute() throws IgniteCheckedException { + @Override public Object execute() throws IgniteException { return null; } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/loadtests/job/GridJobExecutionSingleNodeSemaphoreLoadTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/loadtests/job/GridJobExecutionSingleNodeSemaphoreLoadTest.java b/modules/core/src/test/java/org/gridgain/loadtests/job/GridJobExecutionSingleNodeSemaphoreLoadTest.java index 851a083..fb16475 100644 --- a/modules/core/src/test/java/org/gridgain/loadtests/job/GridJobExecutionSingleNodeSemaphoreLoadTest.java +++ b/modules/core/src/test/java/org/gridgain/loadtests/job/GridJobExecutionSingleNodeSemaphoreLoadTest.java @@ -187,17 +187,17 @@ public class GridJobExecutionSingleNodeSemaphoreLoadTest { private static class GridJobExecutionLoadTestTask implements ComputeTask<Object, Object> { /** {@inheritDoc} */ @Nullable @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, @Nullable Object arg) - throws IgniteCheckedException { + throws IgniteException { return F.asMap(new GridJobExecutionLoadTestJob(), subgrid.get(0)); } /** {@inheritDoc} */ - @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) throws IgniteCheckedException { + @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) throws IgniteException { return REDUCE; } /** {@inheritDoc} */ - @Nullable @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Nullable @Override public Object reduce(List<ComputeJobResult> results) throws IgniteException { return null; } } @@ -207,7 +207,7 @@ public class GridJobExecutionSingleNodeSemaphoreLoadTest { */ private static class GridJobExecutionLoadTestJob implements ComputeJob { /** {@inheritDoc} */ - @Override public Object execute() throws IgniteCheckedException { + @Override public Object execute() throws IgniteException { return null; } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/loadtests/job/GridJobLoadTestJob.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/loadtests/job/GridJobLoadTestJob.java b/modules/core/src/test/java/org/gridgain/loadtests/job/GridJobLoadTestJob.java index c3b293a..1136fef 100644 --- a/modules/core/src/test/java/org/gridgain/loadtests/job/GridJobLoadTestJob.java +++ b/modules/core/src/test/java/org/gridgain/loadtests/job/GridJobLoadTestJob.java @@ -74,7 +74,7 @@ public class GridJobLoadTestJob implements ComputeJob { } /**{@inheritDoc}*/ - @Override public Integer execute() throws IgniteCheckedException { + @Override public Integer execute() throws IgniteException { try { if (log.isInfoEnabled()) log.info("Job started " + getJobInfo()); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/loadtests/job/GridJobLoadTestTask.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/loadtests/job/GridJobLoadTestTask.java b/modules/core/src/test/java/org/gridgain/loadtests/job/GridJobLoadTestTask.java index 4f3f813..5d82f91 100644 --- a/modules/core/src/test/java/org/gridgain/loadtests/job/GridJobLoadTestTask.java +++ b/modules/core/src/test/java/org/gridgain/loadtests/job/GridJobLoadTestTask.java @@ -24,7 +24,7 @@ import static org.apache.ignite.compute.ComputeJobResultPolicy.*; public class GridJobLoadTestTask extends ComputeTaskAdapter<GridJobLoadTestParams, Integer> { /**{@inheritDoc} */ @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, @Nullable GridJobLoadTestParams arg) - throws IgniteCheckedException { + throws IgniteException { assert !subgrid.isEmpty(); Map<ComputeJob, ClusterNode> jobs = new HashMap<>(); @@ -46,13 +46,13 @@ public class GridJobLoadTestTask extends ComputeTaskAdapter<GridJobLoadTestParam * * {@inheritDoc} */ - @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) throws IgniteCheckedException { + @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) throws IgniteException { return res.getException() == null ? WAIT : res.getException().getCause() instanceof AssertionError ? REDUCE : FAILOVER; } /**{@inheritDoc} */ - @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteException { int sum = 0; for (ComputeJobResult r: results) { http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/loadtests/mapper/GridContinuousMapperTask1.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/loadtests/mapper/GridContinuousMapperTask1.java b/modules/core/src/test/java/org/gridgain/loadtests/mapper/GridContinuousMapperTask1.java index 88673d7..0071e15 100644 --- a/modules/core/src/test/java/org/gridgain/loadtests/mapper/GridContinuousMapperTask1.java +++ b/modules/core/src/test/java/org/gridgain/loadtests/mapper/GridContinuousMapperTask1.java @@ -92,7 +92,7 @@ public class GridContinuousMapperTask1 extends ComputeTaskAdapter<Integer, Integ /** {@inheritDoc} */ @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, @Nullable Integer arg) - throws IgniteCheckedException { + throws IgniteException { maxExecs = arg; // Start worker thread. @@ -108,7 +108,7 @@ public class GridContinuousMapperTask1 extends ComputeTaskAdapter<Integer, Integ } /** {@inheritDoc} */ - @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) throws IgniteCheckedException { + @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) throws IgniteException { if (res.getException() != null) throw new IgniteCheckedException(res.getException()); @@ -125,7 +125,7 @@ public class GridContinuousMapperTask1 extends ComputeTaskAdapter<Integer, Integ } /** {@inheritDoc} */ - @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteException { X.println(">>> Reducing task..."); t.interrupt(); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/loadtests/mapper/GridContinuousMapperTask2.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/loadtests/mapper/GridContinuousMapperTask2.java b/modules/core/src/test/java/org/gridgain/loadtests/mapper/GridContinuousMapperTask2.java index 3b78a0e..0d7308a 100644 --- a/modules/core/src/test/java/org/gridgain/loadtests/mapper/GridContinuousMapperTask2.java +++ b/modules/core/src/test/java/org/gridgain/loadtests/mapper/GridContinuousMapperTask2.java @@ -29,7 +29,7 @@ public class GridContinuousMapperTask2 extends ComputeTaskAdapter<int[], Integer /** {@inheritDoc} */ @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, @Nullable int[] jobIds) - throws IgniteCheckedException { + throws IgniteException { Map<ComputeJob, ClusterNode> mappings = new HashMap<>(jobIds.length); Iterator<ClusterNode> nodeIter = g.cluster().forRemotes().nodes().iterator(); @@ -63,7 +63,7 @@ public class GridContinuousMapperTask2 extends ComputeTaskAdapter<int[], Integer } /** {@inheritDoc} */ - @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) throws IgniteCheckedException { + @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) throws IgniteException { TestObject o = res.getData(); X.println("Received job result from node [resId=" + o.getId() + ", node=" + res.getNode().id() + ']'); @@ -72,7 +72,7 @@ public class GridContinuousMapperTask2 extends ComputeTaskAdapter<int[], Integer } /** {@inheritDoc} */ - @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteException { X.println(">>> Reducing task..."); return null; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/loadtests/mergesort/GridMergeSortLoadTask.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/loadtests/mergesort/GridMergeSortLoadTask.java b/modules/core/src/test/java/org/gridgain/loadtests/mergesort/GridMergeSortLoadTask.java index 9795503..e0bc4c2 100644 --- a/modules/core/src/test/java/org/gridgain/loadtests/mergesort/GridMergeSortLoadTask.java +++ b/modules/core/src/test/java/org/gridgain/loadtests/mergesort/GridMergeSortLoadTask.java @@ -54,7 +54,7 @@ public class GridMergeSortLoadTask extends ComputeTaskSplitAdapter<int[], int[]> // Task execution result future. private ComputeTaskFuture<int[]> fut; - @Override public Object execute() throws IgniteCheckedException { + @Override public Object execute() throws IgniteException { if (arr.length == 1) return arr; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/loadtests/streamer/average/TestStage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/loadtests/streamer/average/TestStage.java b/modules/core/src/test/java/org/gridgain/loadtests/streamer/average/TestStage.java index 686d258..56e3ec6 100644 --- a/modules/core/src/test/java/org/gridgain/loadtests/streamer/average/TestStage.java +++ b/modules/core/src/test/java/org/gridgain/loadtests/streamer/average/TestStage.java @@ -27,7 +27,7 @@ class TestStage implements StreamerStage<Integer> { /** {@inheritDoc} */ @Override public Map<String, Collection<?>> run(StreamerContext ctx, Collection<Integer> evts) - throws IgniteCheckedException { + throws IgniteException { ConcurrentMap<String, TestAverage> loc = ctx.localSpace(); TestAverage avg = loc.get("avg"); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/testframework/GridTestUtils.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/testframework/GridTestUtils.java b/modules/core/src/test/java/org/gridgain/testframework/GridTestUtils.java index bdd7042..d6e3883 100644 --- a/modules/core/src/test/java/org/gridgain/testframework/GridTestUtils.java +++ b/modules/core/src/test/java/org/gridgain/testframework/GridTestUtils.java @@ -582,7 +582,7 @@ public final class GridTestUtils { final GridTestSafeThreadFactory thrFactory = new GridTestSafeThreadFactory("async-runner"); final GridFutureAdapter<T> fut = new GridFutureAdapter<T>() { - @Override public boolean cancel() throws IgniteCheckedException { + @Override public boolean cancel() throws IgniteException { super.cancel(); thrFactory.interruptAllThreads(); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/test/java/org/gridgain/testframework/junits/cache/GridAbstractCacheStoreSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/gridgain/testframework/junits/cache/GridAbstractCacheStoreSelfTest.java b/modules/core/src/test/java/org/gridgain/testframework/junits/cache/GridAbstractCacheStoreSelfTest.java index 2c56601..545d975 100644 --- a/modules/core/src/test/java/org/gridgain/testframework/junits/cache/GridAbstractCacheStoreSelfTest.java +++ b/modules/core/src/test/java/org/gridgain/testframework/junits/cache/GridAbstractCacheStoreSelfTest.java @@ -478,7 +478,7 @@ public abstract class GridAbstractCacheStoreSelfTest<T extends GridCacheStore<Ob } /** {@inheritDoc} */ - @Override public void close() throws IgniteCheckedException { + @Override public void close() throws IgniteException { // No-op. } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/GridCacheDeploymentTestTask1.java ---------------------------------------------------------------------- diff --git a/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/GridCacheDeploymentTestTask1.java b/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/GridCacheDeploymentTestTask1.java index 8a69763..230f6eb 100644 --- a/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/GridCacheDeploymentTestTask1.java +++ b/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/GridCacheDeploymentTestTask1.java @@ -29,13 +29,13 @@ public class GridCacheDeploymentTestTask1 extends ComputeTaskAdapter<ClusterNode /** {@inheritDoc} */ @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, - @Nullable ClusterNode node) throws IgniteCheckedException { + @Nullable ClusterNode node) throws IgniteException { return F.asMap( new ComputeJobAdapter() { @IgniteInstanceResource private Ignite ignite; - @Override public Object execute() throws IgniteCheckedException { + @Override public Object execute() throws IgniteException { X.println("Executing GridCacheDeploymentTestTask1 job on node " + ignite.cluster().localNode().id()); @@ -52,7 +52,7 @@ public class GridCacheDeploymentTestTask1 extends ComputeTaskAdapter<ClusterNode } /** {@inheritDoc} */ - @Nullable @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Nullable @Override public Object reduce(List<ComputeJobResult> results) throws IgniteException { return null; } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/GridCacheDeploymentTestTask2.java ---------------------------------------------------------------------- diff --git a/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/GridCacheDeploymentTestTask2.java b/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/GridCacheDeploymentTestTask2.java index 0264e06..406654a 100644 --- a/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/GridCacheDeploymentTestTask2.java +++ b/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/GridCacheDeploymentTestTask2.java @@ -25,7 +25,7 @@ import java.util.*; public class GridCacheDeploymentTestTask2 extends ComputeTaskAdapter<ClusterNode, Object> { /** {@inheritDoc} */ @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, - @Nullable ClusterNode node) throws IgniteCheckedException { + @Nullable ClusterNode node) throws IgniteException { return F.asMap( new ComputeJobAdapter() { @IgniteInstanceResource @@ -43,7 +43,7 @@ public class GridCacheDeploymentTestTask2 extends ComputeTaskAdapter<ClusterNode } /** {@inheritDoc} */ - @Nullable @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Nullable @Override public Object reduce(List<ComputeJobResult> results) throws IgniteException { return null; } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/GridCacheDeploymentTestTask3.java ---------------------------------------------------------------------- diff --git a/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/GridCacheDeploymentTestTask3.java b/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/GridCacheDeploymentTestTask3.java index f70e4c8..a151777 100644 --- a/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/GridCacheDeploymentTestTask3.java +++ b/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/GridCacheDeploymentTestTask3.java @@ -25,7 +25,7 @@ import java.util.*; public class GridCacheDeploymentTestTask3 extends ComputeTaskAdapter<T2<ClusterNode, String>, Object> { /** {@inheritDoc} */ @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, - @Nullable T2<ClusterNode, String> tup) throws IgniteCheckedException { + @Nullable T2<ClusterNode, String> tup) throws IgniteException { final String val = tup.getValue(); return F.asMap( @@ -33,7 +33,7 @@ public class GridCacheDeploymentTestTask3 extends ComputeTaskAdapter<T2<ClusterN @IgniteInstanceResource private Ignite ignite; - @Override public Object execute() throws IgniteCheckedException { + @Override public Object execute() throws IgniteException { X.println("Executing GridCacheDeploymentTestTask3 job on node " + ignite.cluster().localNode().id()); @@ -48,7 +48,7 @@ public class GridCacheDeploymentTestTask3 extends ComputeTaskAdapter<T2<ClusterN } /** {@inheritDoc} */ - @Nullable @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Nullable @Override public Object reduce(List<ComputeJobResult> results) throws IgniteException { return null; } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/GridP2PContinuousDeploymentTask1.java ---------------------------------------------------------------------- diff --git a/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/GridP2PContinuousDeploymentTask1.java b/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/GridP2PContinuousDeploymentTask1.java index 9cc627c..7a695a8 100644 --- a/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/GridP2PContinuousDeploymentTask1.java +++ b/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/GridP2PContinuousDeploymentTask1.java @@ -23,12 +23,12 @@ import java.util.*; */ public class GridP2PContinuousDeploymentTask1 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 { return Collections.singleton(new ComputeJobAdapter() { @IgniteInstanceResource private Ignite ignite; - @Override public Object execute() throws IgniteCheckedException { + @Override public Object execute() throws IgniteException { X.println(">>> Executing GridP2PContinuousDeploymentTask1 job."); ignite.cache(null).putx("key", new GridTestUserResource()); @@ -39,7 +39,7 @@ public class GridP2PContinuousDeploymentTask1 extends ComputeTaskSplitAdapter<Ob } /** {@inheritDoc} */ - @Nullable @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Nullable @Override public Object reduce(List<ComputeJobResult> results) throws IgniteException { return null; } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/GridP2PContinuousDeploymentTask2.java ---------------------------------------------------------------------- diff --git a/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/GridP2PContinuousDeploymentTask2.java b/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/GridP2PContinuousDeploymentTask2.java index 3b136fc..67ce859 100644 --- a/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/GridP2PContinuousDeploymentTask2.java +++ b/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/GridP2PContinuousDeploymentTask2.java @@ -22,7 +22,7 @@ import java.util.*; */ public class GridP2PContinuousDeploymentTask2 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 { return Collections.singleton(new ComputeJobAdapter() { @Override public Object execute() { X.println(">>> Executing GridP2PContinuousDeploymentTask2 job."); @@ -33,7 +33,7 @@ public class GridP2PContinuousDeploymentTask2 extends ComputeTaskSplitAdapter<Ob } /** {@inheritDoc} */ - @Nullable @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Nullable @Override public Object reduce(List<ComputeJobResult> results) throws IgniteException { return null; } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/GridP2PTestTaskExternalPath1.java ---------------------------------------------------------------------- diff --git a/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/GridP2PTestTaskExternalPath1.java b/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/GridP2PTestTaskExternalPath1.java index b9c6e9e..645117a 100644 --- a/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/GridP2PTestTaskExternalPath1.java +++ b/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/GridP2PTestTaskExternalPath1.java @@ -31,7 +31,7 @@ public class GridP2PTestTaskExternalPath1 extends ComputeTaskAdapter<Object, int * {@inheritDoc} */ @SuppressWarnings({"unchecked"}) - @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 { if (log.isInfoEnabled()) { log.info("Mapping [task=" + this + ", subgrid=" + F.viewReadOnly(subgrid, F.node2id()) + ", arg=" + arg + ']'); @@ -73,7 +73,7 @@ public class GridP2PTestTaskExternalPath1 extends ComputeTaskAdapter<Object, int /** * {@inheritDoc} */ - @Override public int[] reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public int[] reduce(List<ComputeJobResult> results) throws IgniteException { return results.get(0).getData(); } @@ -123,7 +123,7 @@ public class GridP2PTestTaskExternalPath1 extends ComputeTaskAdapter<Object, int } /** {@inheritDoc} */ - @Override public int[] execute() throws IgniteCheckedException { + @Override public int[] execute() throws IgniteException { assert locNodeId.equals(argument(0)); log.info("Running job on node: " + g.cluster().localNode().id()); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/GridP2PTestTaskExternalPath2.java ---------------------------------------------------------------------- diff --git a/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/GridP2PTestTaskExternalPath2.java b/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/GridP2PTestTaskExternalPath2.java index 743eeb6..c74fc14 100644 --- a/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/GridP2PTestTaskExternalPath2.java +++ b/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/GridP2PTestTaskExternalPath2.java @@ -31,7 +31,7 @@ public class GridP2PTestTaskExternalPath2 extends ComputeTaskAdapter<Object, int * {@inheritDoc} */ @SuppressWarnings({"unchecked"}) - @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 { if (log.isInfoEnabled()) { log.info("Mapping [task=" + this + ", subgrid=" + F.viewReadOnly(subgrid, F.node2id()) + ", arg=" + arg + ']'); @@ -73,7 +73,7 @@ public class GridP2PTestTaskExternalPath2 extends ComputeTaskAdapter<Object, int /** * {@inheritDoc} */ - @Override public int[] reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public int[] reduce(List<ComputeJobResult> results) throws IgniteException { return results.get(0).getData(); } @@ -114,7 +114,7 @@ public class GridP2PTestTaskExternalPath2 extends ComputeTaskAdapter<Object, int /** * {@inheritDoc} */ - @Override public int[] execute() throws IgniteCheckedException { + @Override public int[] execute() throws IgniteException { assert locNodeId.equals(argument(0)); if (sleep) { http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/GridSingleSplitTestTask.java ---------------------------------------------------------------------- diff --git a/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/GridSingleSplitTestTask.java b/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/GridSingleSplitTestTask.java index d54f078..efbcff3 100644 --- a/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/GridSingleSplitTestTask.java +++ b/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/GridSingleSplitTestTask.java @@ -23,7 +23,7 @@ public class GridSingleSplitTestTask extends ComputeTaskSplitAdapter<Integer, In /** * {@inheritDoc} */ - @Override protected Collection<? extends ComputeJob> split(int gridSize, Integer arg) throws IgniteCheckedException { + @Override protected Collection<? extends ComputeJob> split(int gridSize, Integer arg) throws IgniteException { assert gridSize > 0 : "Subgrid cannot be empty."; Collection<ComputeJobAdapter> jobs = new ArrayList<>(gridSize); @@ -37,7 +37,7 @@ public class GridSingleSplitTestTask extends ComputeTaskSplitAdapter<Integer, In /** * {@inheritDoc} */ - @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Integer reduce(List<ComputeJobResult> results) throws IgniteException { int retVal = 0; for (ComputeJobResult res : results) { http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/JobStealingTask.java ---------------------------------------------------------------------- diff --git a/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/JobStealingTask.java b/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/JobStealingTask.java index c68a218..260a664 100644 --- a/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/JobStealingTask.java +++ b/modules/extdata/p2p/src/main/java/org/gridgain/grid/tests/p2p/JobStealingTask.java @@ -29,7 +29,7 @@ public class JobStealingTask extends ComputeTaskAdapter<Object, Map<UUID, Intege /** {@inheritDoc} */ @SuppressWarnings("ForLoopReplaceableByForEach") @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, - @Nullable Object arg) throws IgniteCheckedException { + @Nullable Object arg) throws IgniteException { assert !subgrid.isEmpty(); Map<ComputeJobAdapter, ClusterNode> map = U.newHashMap(subgrid.size()); @@ -43,7 +43,7 @@ public class JobStealingTask extends ComputeTaskAdapter<Object, Map<UUID, Intege /** {@inheritDoc} */ @SuppressWarnings("SuspiciousMethodCalls") - @Override public Map<UUID, Integer> reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Map<UUID, Integer> reduce(List<ComputeJobResult> results) throws IgniteException { Map<UUID, Integer> ret = U.newHashMap(results.size()); for (ComputeJobResult res : results) { @@ -78,7 +78,7 @@ public class JobStealingTask extends ComputeTaskAdapter<Object, Map<UUID, Intege } /** {@inheritDoc} */ - @Override public Serializable execute() throws IgniteCheckedException { + @Override public Serializable execute() throws IgniteException { log.info("Started job on node: " + ignite.cluster().localNode().id()); try { http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentAbstractTestTask.java ---------------------------------------------------------------------- diff --git a/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentAbstractTestTask.java b/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentAbstractTestTask.java index 924eba8..4884f02 100644 --- a/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentAbstractTestTask.java +++ b/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentAbstractTestTask.java @@ -22,14 +22,14 @@ public abstract class GridUriDeploymentAbstractTestTask extends ComputeTaskSplit /** * {@inheritDoc} */ - @Override public Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteCheckedException { + @Override public Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteException { return null; } /** * {@inheritDoc} */ - @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Object reduce(List<ComputeJobResult> results) throws IgniteException { return null; } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentInnerTestTask.java ---------------------------------------------------------------------- diff --git a/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentInnerTestTask.java b/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentInnerTestTask.java index 5d063c2..e2d32ed 100644 --- a/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentInnerTestTask.java +++ b/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentInnerTestTask.java @@ -24,12 +24,12 @@ public class GridUriDeploymentInnerTestTask { */ public class GridInnerTestTask extends ComputeTaskSplitAdapter<Object, Object> { /** {@inheritDoc} */ - @Override public Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteCheckedException { + @Override public Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteException { return null; } /** {@inheritDoc} */ - @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Object reduce(List<ComputeJobResult> results) throws IgniteException { return null; } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentNonePublicTestTask.java ---------------------------------------------------------------------- diff --git a/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentNonePublicTestTask.java b/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentNonePublicTestTask.java index 8823996..7336282 100644 --- a/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentNonePublicTestTask.java +++ b/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentNonePublicTestTask.java @@ -20,12 +20,12 @@ import java.util.*; */ class GridUriDeploymentNonePublicTestTask extends ComputeTaskSplitAdapter<Object, Object> { /** {@inheritDoc} */ - @Override public Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteCheckedException { + @Override public Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteException { return null; } /** {@inheritDoc} */ - @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Object reduce(List<ComputeJobResult> results) throws IgniteException { return null; } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestTask0.java ---------------------------------------------------------------------- diff --git a/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestTask0.java b/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestTask0.java index bd43201..883ef3c 100644 --- a/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestTask0.java +++ b/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestTask0.java @@ -20,12 +20,12 @@ import java.util.*; */ public class GridUriDeploymentTestTask0 extends ComputeTaskSplitAdapter<Object, Object> { /** {@inheritDoc} */ - @Override public Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteCheckedException { + @Override public Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteException { return null; } /** {@inheritDoc} */ - @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Object reduce(List<ComputeJobResult> results) throws IgniteException { return null; } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestTask1.java ---------------------------------------------------------------------- diff --git a/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestTask1.java b/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestTask1.java index 892b9a9..40ba731 100644 --- a/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestTask1.java +++ b/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestTask1.java @@ -42,14 +42,14 @@ public class GridUriDeploymentTestTask1 extends ComputeTaskSplitAdapter<Object, /** * {@inheritDoc} */ - @Override public Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteCheckedException { + @Override public Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteException { return null; } /** * {@inheritDoc} */ - @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Object reduce(List<ComputeJobResult> results) throws IgniteException { return null; } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestTask2.java ---------------------------------------------------------------------- diff --git a/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestTask2.java b/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestTask2.java index bbee39f..dc16af0 100644 --- a/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestTask2.java +++ b/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestTask2.java @@ -46,7 +46,7 @@ public class GridUriDeploymentTestTask2 extends ComputeTaskSplitAdapter<Object, /** * {@inheritDoc} */ - @Override public Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteCheckedException { + @Override public Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteException { System.out.println("Split is called: " + this); return null; @@ -55,7 +55,7 @@ public class GridUriDeploymentTestTask2 extends ComputeTaskSplitAdapter<Object, /** * {@inheritDoc} */ - @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Object reduce(List<ComputeJobResult> results) throws IgniteException { System.out.println("Reduce is called."); return null; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestTask3.java ---------------------------------------------------------------------- diff --git a/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestTask3.java b/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestTask3.java index 738aa94..f8f874d 100644 --- a/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestTask3.java +++ b/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestTask3.java @@ -22,14 +22,14 @@ public class GridUriDeploymentTestTask3 extends ComputeTaskSplitAdapter<Object, /** * {@inheritDoc} */ - @Override public Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteCheckedException { + @Override public Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteException { return null; } /** * {@inheritDoc} */ - @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Object reduce(List<ComputeJobResult> results) throws IgniteException { return null; } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestTask4.java ---------------------------------------------------------------------- diff --git a/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestTask4.java b/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestTask4.java index 738cd13..3d8bc87 100644 --- a/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestTask4.java +++ b/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestTask4.java @@ -22,14 +22,14 @@ public class GridUriDeploymentTestTask4 extends ComputeTaskSplitAdapter<Object, /** * {@inheritDoc} */ - @Override public Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteCheckedException { + @Override public Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteException { return null; } /** * {@inheritDoc} */ - @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Object reduce(List<ComputeJobResult> results) throws IgniteException { return null; } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestTask5.java ---------------------------------------------------------------------- diff --git a/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestTask5.java b/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestTask5.java index 99af880..d1b0248 100644 --- a/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestTask5.java +++ b/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestTask5.java @@ -22,14 +22,14 @@ public class GridUriDeploymentTestTask5 extends ComputeTaskSplitAdapter<Object, /** * {@inheritDoc} */ - @Override public Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteCheckedException { + @Override public Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteException { return null; } /** * {@inheritDoc} */ - @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Object reduce(List<ComputeJobResult> results) throws IgniteException { return null; } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestTask6.java ---------------------------------------------------------------------- diff --git a/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestTask6.java b/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestTask6.java index 7381dad..b82ea95 100644 --- a/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestTask6.java +++ b/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestTask6.java @@ -22,14 +22,14 @@ public class GridUriDeploymentTestTask6 extends ComputeTaskSplitAdapter<Object, /** * {@inheritDoc} */ - @Override public Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteCheckedException { + @Override public Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteException { return null; } /** * {@inheritDoc} */ - @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Object reduce(List<ComputeJobResult> results) throws IgniteException { return null; } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestWithNameTask0.java ---------------------------------------------------------------------- diff --git a/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestWithNameTask0.java b/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestWithNameTask0.java index eaa78d1..79cedfc 100644 --- a/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestWithNameTask0.java +++ b/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestWithNameTask0.java @@ -23,14 +23,14 @@ public class GridUriDeploymentTestWithNameTask0 extends ComputeTaskSplitAdapter< /** * {@inheritDoc} */ - @Override public Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteCheckedException { + @Override public Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteException { return null; } /** * {@inheritDoc} */ - @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Object reduce(List<ComputeJobResult> results) throws IgniteException { return null; } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestWithNameTask3.java ---------------------------------------------------------------------- diff --git a/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestWithNameTask3.java b/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestWithNameTask3.java index f8a014b..a848584 100644 --- a/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestWithNameTask3.java +++ b/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestWithNameTask3.java @@ -23,14 +23,14 @@ public class GridUriDeploymentTestWithNameTask3 extends ComputeTaskSplitAdapter< /** * {@inheritDoc} */ - @Override public Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteCheckedException { + @Override public Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteException { return null; } /** * {@inheritDoc} */ - @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Object reduce(List<ComputeJobResult> results) throws IgniteException { return null; } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestWithNameTask4.java ---------------------------------------------------------------------- diff --git a/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestWithNameTask4.java b/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestWithNameTask4.java index 2b33531..740f478 100644 --- a/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestWithNameTask4.java +++ b/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestWithNameTask4.java @@ -23,14 +23,14 @@ public class GridUriDeploymentTestWithNameTask4 extends ComputeTaskSplitAdapter< /** * {@inheritDoc} */ - @Override public Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteCheckedException { + @Override public Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteException { return null; } /** * {@inheritDoc} */ - @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Object reduce(List<ComputeJobResult> results) throws IgniteException { return null; } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestWithNameTask5.java ---------------------------------------------------------------------- diff --git a/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestWithNameTask5.java b/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestWithNameTask5.java index f59cefa..ebf6b79 100644 --- a/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestWithNameTask5.java +++ b/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestWithNameTask5.java @@ -23,14 +23,14 @@ public class GridUriDeploymentTestWithNameTask5 extends ComputeTaskSplitAdapter< /** * {@inheritDoc} */ - @Override public Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteCheckedException { + @Override public Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteException { return null; } /** * {@inheritDoc} */ - @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Object reduce(List<ComputeJobResult> results) throws IgniteException { return null; } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestWithNameTask6.java ---------------------------------------------------------------------- diff --git a/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestWithNameTask6.java b/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestWithNameTask6.java index b24da56..a00c09f 100644 --- a/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestWithNameTask6.java +++ b/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestWithNameTask6.java @@ -23,14 +23,14 @@ public class GridUriDeploymentTestWithNameTask6 extends ComputeTaskSplitAdapter< /** * {@inheritDoc} */ - @Override public Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteCheckedException { + @Override public Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteException { return null; } /** * {@inheritDoc} */ - @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Object reduce(List<ComputeJobResult> results) throws IgniteException { return null; } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestWithNameTask7.java ---------------------------------------------------------------------- diff --git a/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestWithNameTask7.java b/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestWithNameTask7.java index 3deb38b..fc21b94 100644 --- a/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestWithNameTask7.java +++ b/modules/extdata/uri/src/main/java/org/apache/ignite/spi/deployment/uri/tasks/GridUriDeploymentTestWithNameTask7.java @@ -23,14 +23,14 @@ public class GridUriDeploymentTestWithNameTask7 extends ComputeTaskSplitAdapter< /** * {@inheritDoc} */ - @Override public Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteCheckedException { + @Override public Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteException { return null; } /** * {@inheritDoc} */ - @Override public Object reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Override public Object reduce(List<ComputeJobResult> results) throws IgniteException { return null; } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/hadoop/src/main/java/org/gridgain/grid/kernal/ggfs/hadoop/GridGgfsHadoopFileSystemWrapper.java ---------------------------------------------------------------------- diff --git a/modules/hadoop/src/main/java/org/gridgain/grid/kernal/ggfs/hadoop/GridGgfsHadoopFileSystemWrapper.java b/modules/hadoop/src/main/java/org/gridgain/grid/kernal/ggfs/hadoop/GridGgfsHadoopFileSystemWrapper.java index 39e1b7e..6addadc 100644 --- a/modules/hadoop/src/main/java/org/gridgain/grid/kernal/ggfs/hadoop/GridGgfsHadoopFileSystemWrapper.java +++ b/modules/hadoop/src/main/java/org/gridgain/grid/kernal/ggfs/hadoop/GridGgfsHadoopFileSystemWrapper.java @@ -139,7 +139,7 @@ public class GridGgfsHadoopFileSystemWrapper implements IgniteFsFileSystem, Auto } /** {@inheritDoc} */ - @Override public boolean exists(IgniteFsPath path) throws IgniteCheckedException { + @Override public boolean exists(IgniteFsPath path) throws IgniteException { try { return fileSys.exists(convert(path)); } @@ -149,7 +149,7 @@ public class GridGgfsHadoopFileSystemWrapper implements IgniteFsFileSystem, Auto } /** {@inheritDoc} */ - @Nullable @Override public IgniteFsFile update(IgniteFsPath path, Map<String, String> props) throws IgniteCheckedException { + @Nullable @Override public IgniteFsFile update(IgniteFsPath path, Map<String, String> props) throws IgniteException { GridGgfsHadoopFSProperties props0 = new GridGgfsHadoopFSProperties(props); try { @@ -168,7 +168,7 @@ public class GridGgfsHadoopFileSystemWrapper implements IgniteFsFileSystem, Auto } /** {@inheritDoc} */ - @Override public void rename(IgniteFsPath src, IgniteFsPath dest) throws IgniteCheckedException { + @Override public void rename(IgniteFsPath src, IgniteFsPath dest) throws IgniteException { // Delegate to the secondary file system. try { if (!fileSys.rename(convert(src), convert(dest))) @@ -181,7 +181,7 @@ public class GridGgfsHadoopFileSystemWrapper implements IgniteFsFileSystem, Auto } /** {@inheritDoc} */ - @Override public boolean delete(IgniteFsPath path, boolean recursive) throws IgniteCheckedException { + @Override public boolean delete(IgniteFsPath path, boolean recursive) throws IgniteException { try { return fileSys.delete(convert(path), recursive); } @@ -191,7 +191,7 @@ public class GridGgfsHadoopFileSystemWrapper implements IgniteFsFileSystem, Auto } /** {@inheritDoc} */ - @Override public void mkdirs(IgniteFsPath path) throws IgniteCheckedException { + @Override public void mkdirs(IgniteFsPath path) throws IgniteException { try { if (!fileSys.mkdirs(convert(path))) throw new IgniteCheckedException("Failed to make directories [path=" + path + "]"); @@ -202,7 +202,7 @@ public class GridGgfsHadoopFileSystemWrapper implements IgniteFsFileSystem, Auto } /** {@inheritDoc} */ - @Override public void mkdirs(IgniteFsPath path, @Nullable Map<String, String> props) throws IgniteCheckedException { + @Override public void mkdirs(IgniteFsPath path, @Nullable Map<String, String> props) throws IgniteException { try { if (!fileSys.mkdirs(convert(path), new GridGgfsHadoopFSProperties(props).permission())) throw new IgniteCheckedException("Failed to make directories [path=" + path + ", props=" + props + "]"); @@ -213,7 +213,7 @@ public class GridGgfsHadoopFileSystemWrapper implements IgniteFsFileSystem, Auto } /** {@inheritDoc} */ - @Override public Collection<IgniteFsPath> listPaths(IgniteFsPath path) throws IgniteCheckedException { + @Override public Collection<IgniteFsPath> listPaths(IgniteFsPath path) throws IgniteException { try { FileStatus[] statuses = fileSys.listStatus(convert(path)); @@ -236,7 +236,7 @@ public class GridGgfsHadoopFileSystemWrapper implements IgniteFsFileSystem, Auto } /** {@inheritDoc} */ - @Override public Collection<IgniteFsFile> listFiles(IgniteFsPath path) throws IgniteCheckedException { + @Override public Collection<IgniteFsFile> listFiles(IgniteFsPath path) throws IgniteException { try { FileStatus[] statuses = fileSys.listStatus(convert(path)); @@ -269,7 +269,7 @@ public class GridGgfsHadoopFileSystemWrapper implements IgniteFsFileSystem, Auto } /** {@inheritDoc} */ - @Override public OutputStream create(IgniteFsPath path, boolean overwrite) throws IgniteCheckedException { + @Override public OutputStream create(IgniteFsPath path, boolean overwrite) throws IgniteException { try { return fileSys.create(convert(path), overwrite); } @@ -280,7 +280,7 @@ public class GridGgfsHadoopFileSystemWrapper implements IgniteFsFileSystem, Auto /** {@inheritDoc} */ @Override public OutputStream create(IgniteFsPath path, int bufSize, boolean overwrite, int replication, - long blockSize, @Nullable Map<String, String> props) throws IgniteCheckedException { + long blockSize, @Nullable Map<String, String> props) throws IgniteException { GridGgfsHadoopFSProperties props0 = new GridGgfsHadoopFSProperties(props != null ? props : Collections.<String, String>emptyMap()); @@ -297,7 +297,7 @@ public class GridGgfsHadoopFileSystemWrapper implements IgniteFsFileSystem, Auto /** {@inheritDoc} */ @Override public OutputStream append(IgniteFsPath path, int bufSize, boolean create, - @Nullable Map<String, String> props) throws IgniteCheckedException { + @Nullable Map<String, String> props) throws IgniteException { try { return fileSys.append(convert(path), bufSize); } @@ -307,7 +307,7 @@ public class GridGgfsHadoopFileSystemWrapper implements IgniteFsFileSystem, Auto } /** {@inheritDoc} */ - @Override public IgniteFsFile info(final IgniteFsPath path) throws IgniteCheckedException { + @Override public IgniteFsFile info(final IgniteFsPath path) throws IgniteException { try { final FileStatus status = fileSys.getFileStatus(convert(path)); @@ -380,7 +380,7 @@ public class GridGgfsHadoopFileSystemWrapper implements IgniteFsFileSystem, Auto } /** {@inheritDoc} */ - @Override public long usedSpaceSize() throws IgniteCheckedException { + @Override public long usedSpaceSize() throws IgniteException { try { return fileSys.getContentSummary(new Path(fileSys.getUri())).getSpaceConsumed(); } @@ -395,7 +395,7 @@ public class GridGgfsHadoopFileSystemWrapper implements IgniteFsFileSystem, Auto } /** {@inheritDoc} */ - @Override public void close() throws IgniteCheckedException { + @Override public void close() throws IgniteException { try { fileSys.close(); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/hadoop/src/main/java/org/gridgain/grid/kernal/processors/hadoop/jobtracker/GridHadoopJobTracker.java ---------------------------------------------------------------------- diff --git a/modules/hadoop/src/main/java/org/gridgain/grid/kernal/processors/hadoop/jobtracker/GridHadoopJobTracker.java b/modules/hadoop/src/main/java/org/gridgain/grid/kernal/processors/hadoop/jobtracker/GridHadoopJobTracker.java index c2ee568..f40cf88 100644 --- a/modules/hadoop/src/main/java/org/gridgain/grid/kernal/processors/hadoop/jobtracker/GridHadoopJobTracker.java +++ b/modules/hadoop/src/main/java/org/gridgain/grid/kernal/processors/hadoop/jobtracker/GridHadoopJobTracker.java @@ -138,7 +138,7 @@ public class GridHadoopJobTracker extends GridHadoopComponent { try { // Must process query callback in a separate thread to avoid deadlocks. evtProcSvc.submit(new EventHandler() { - @Override protected void body() throws IgniteCheckedException { + @Override protected void body() throws IgniteException { processJobMetadataUpdates(evts); } }); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/hadoop/src/main/java/org/gridgain/grid/kernal/processors/hadoop/proto/GridHadoopProtocolTaskAdapter.java ---------------------------------------------------------------------- diff --git a/modules/hadoop/src/main/java/org/gridgain/grid/kernal/processors/hadoop/proto/GridHadoopProtocolTaskAdapter.java b/modules/hadoop/src/main/java/org/gridgain/grid/kernal/processors/hadoop/proto/GridHadoopProtocolTaskAdapter.java index f660c0c..2b177f2 100644 --- a/modules/hadoop/src/main/java/org/gridgain/grid/kernal/processors/hadoop/proto/GridHadoopProtocolTaskAdapter.java +++ b/modules/hadoop/src/main/java/org/gridgain/grid/kernal/processors/hadoop/proto/GridHadoopProtocolTaskAdapter.java @@ -26,18 +26,18 @@ import java.util.*; public abstract class GridHadoopProtocolTaskAdapter<R> implements ComputeTask<GridHadoopProtocolTaskArguments, R> { /** {@inheritDoc} */ @Nullable @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, - @Nullable GridHadoopProtocolTaskArguments arg) throws IgniteCheckedException { + @Nullable GridHadoopProtocolTaskArguments arg) throws IgniteException { return Collections.singletonMap(new Job(arg), subgrid.get(0)); } /** {@inheritDoc} */ @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) - throws IgniteCheckedException { + throws IgniteException { return ComputeJobResultPolicy.REDUCE; } /** {@inheritDoc} */ - @Nullable @Override public R reduce(List<ComputeJobResult> results) throws IgniteCheckedException { + @Nullable @Override public R reduce(List<ComputeJobResult> results) throws IgniteException { if (!F.isEmpty(results)) { ComputeJobResult res = results.get(0); @@ -79,7 +79,7 @@ public abstract class GridHadoopProtocolTaskAdapter<R> implements ComputeTask<Gr } /** {@inheritDoc} */ - @Nullable @Override public Object execute() throws IgniteCheckedException { + @Nullable @Override public Object execute() throws IgniteException { return run(jobCtx, ignite.hadoop(), args); } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/hadoop/src/main/java/org/gridgain/grid/kernal/processors/hadoop/shuffle/GridHadoopShuffleJob.java ---------------------------------------------------------------------- diff --git a/modules/hadoop/src/main/java/org/gridgain/grid/kernal/processors/hadoop/shuffle/GridHadoopShuffleJob.java b/modules/hadoop/src/main/java/org/gridgain/grid/kernal/processors/hadoop/shuffle/GridHadoopShuffleJob.java index 1a8614f..e907822 100644 --- a/modules/hadoop/src/main/java/org/gridgain/grid/kernal/processors/hadoop/shuffle/GridHadoopShuffleJob.java +++ b/modules/hadoop/src/main/java/org/gridgain/grid/kernal/processors/hadoop/shuffle/GridHadoopShuffleJob.java @@ -395,7 +395,7 @@ public class GridHadoopShuffleJob<T> implements AutoCloseable { } /** {@inheritDoc} */ - @Override public void close() throws IgniteCheckedException { + @Override public void close() throws IgniteException { if (snd != null) { snd.cancel(); @@ -575,7 +575,7 @@ public class GridHadoopShuffleJob<T> implements AutoCloseable { } /** {@inheritDoc} */ - @Override public void close() throws IgniteCheckedException { + @Override public void close() throws IgniteException { for (GridHadoopTaskOutput adder : adders) { if (adder != null) adder.close(); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/hadoop/src/main/java/org/gridgain/grid/kernal/processors/hadoop/shuffle/collections/GridHadoopConcurrentHashMultimap.java ---------------------------------------------------------------------- diff --git a/modules/hadoop/src/main/java/org/gridgain/grid/kernal/processors/hadoop/shuffle/collections/GridHadoopConcurrentHashMultimap.java b/modules/hadoop/src/main/java/org/gridgain/grid/kernal/processors/hadoop/shuffle/collections/GridHadoopConcurrentHashMultimap.java index 6265a99..b45cae0 100644 --- a/modules/hadoop/src/main/java/org/gridgain/grid/kernal/processors/hadoop/shuffle/collections/GridHadoopConcurrentHashMultimap.java +++ b/modules/hadoop/src/main/java/org/gridgain/grid/kernal/processors/hadoop/shuffle/collections/GridHadoopConcurrentHashMultimap.java @@ -169,7 +169,7 @@ public class GridHadoopConcurrentHashMultimap extends GridHadoopHashMultimapBase assert s != State.REHASHING; return new Input(taskCtx) { - @Override public void close() throws IgniteCheckedException { + @Override public void close() throws IgniteException { if (inputs.decrementAndGet() < 0) throw new IllegalStateException(); @@ -535,7 +535,7 @@ public class GridHadoopConcurrentHashMultimap extends GridHadoopHashMultimapBase } /** {@inheritDoc} */ - @Override public void close() throws IgniteCheckedException { + @Override public void close() throws IgniteException { if (!adders.remove(this)) throw new IllegalStateException(); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/hadoop/src/main/java/org/gridgain/grid/kernal/processors/hadoop/shuffle/collections/GridHadoopHashMultimapBase.java ---------------------------------------------------------------------- diff --git a/modules/hadoop/src/main/java/org/gridgain/grid/kernal/processors/hadoop/shuffle/collections/GridHadoopHashMultimapBase.java b/modules/hadoop/src/main/java/org/gridgain/grid/kernal/processors/hadoop/shuffle/collections/GridHadoopHashMultimapBase.java index 8616a70..2b343b4 100644 --- a/modules/hadoop/src/main/java/org/gridgain/grid/kernal/processors/hadoop/shuffle/collections/GridHadoopHashMultimapBase.java +++ b/modules/hadoop/src/main/java/org/gridgain/grid/kernal/processors/hadoop/shuffle/collections/GridHadoopHashMultimapBase.java @@ -193,7 +193,7 @@ public abstract class GridHadoopHashMultimapBase extends GridHadoopMultimapBase } /** {@inheritDoc} */ - @Override public void close() throws IgniteCheckedException { + @Override public void close() throws IgniteException { keyReader.close(); valReader.close(); }
