http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsAbstractSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsAbstractSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsAbstractSelfTest.java index 9279b08..a7e6780 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsAbstractSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsAbstractSelfTest.java @@ -2161,10 +2161,9 @@ public abstract class IgfsAbstractSelfTest extends IgfsCommonAbstractTest { * @param overwrite Overwrite flag. * @param chunks Data chunks. * @throws IOException In case of IO exception. - * @throws IgniteCheckedException In case of Grid exception. */ - protected static void createFile(Igfs igfs, IgfsPath file, boolean overwrite, - @Nullable byte[]... chunks) throws IOException, IgniteCheckedException { + protected static void createFile(Igfs igfs, IgfsPath file, boolean overwrite, @Nullable byte[]... chunks) + throws IOException { OutputStream os = null; try {
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsProcessorSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsProcessorSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsProcessorSelfTest.java index 7ff93a2..ead7511 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsProcessorSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsProcessorSelfTest.java @@ -960,9 +960,8 @@ public class IgfsProcessorSelfTest extends IgfsCommonAbstractTest { * * @param path Directory path to validate listing for. * @param item List of directory items. - * @throws IgniteCheckedException If failed. */ - private void assertListDir(String path, String... item) throws IgniteCheckedException { + private void assertListDir(String path, String... item) { Collection<IgfsFile> files = igfs.listFiles(new IgfsPath(path)); List<String> names = new ArrayList<>(item.length); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/processors/streamer/GridStreamerEvictionSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/streamer/GridStreamerEvictionSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/streamer/GridStreamerEvictionSelfTest.java index 48b6259..03ed31f 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/streamer/GridStreamerEvictionSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/streamer/GridStreamerEvictionSelfTest.java @@ -99,7 +99,7 @@ public class GridStreamerEvictionSelfTest extends GridCommonAbstractTest { SC stage = new SC() { @SuppressWarnings("unchecked") @Override public Map<String, Collection<?>> applyx(String stageName, StreamerContext ctx, - Collection<Object> evts) throws IgniteCheckedException { + Collection<Object> evts) { assert evts.size() == 1; if (ctx.nextStageName() == null) { http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/processors/streamer/GridStreamerSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/streamer/GridStreamerSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/streamer/GridStreamerSelfTest.java index e3009df..19b9c67 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/streamer/GridStreamerSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/streamer/GridStreamerSelfTest.java @@ -458,7 +458,7 @@ public class GridStreamerSelfTest extends GridCommonAbstractTest { SC stage = new SC() { @SuppressWarnings("unchecked") @Override public Map<String, Collection<?>> applyx(String stageName, StreamerContext ctx, - Collection<Object> evts) throws IgniteCheckedException { + Collection<Object> evts) { String nextStage = ctx.nextStageName(); ctx.window().enqueueAll(evts); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/loadtests/cache/GridCacheDataStructuresLoadTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/loadtests/cache/GridCacheDataStructuresLoadTest.java b/modules/core/src/test/java/org/apache/ignite/loadtests/cache/GridCacheDataStructuresLoadTest.java index da677e1..20989f4 100644 --- a/modules/core/src/test/java/org/apache/ignite/loadtests/cache/GridCacheDataStructuresLoadTest.java +++ b/modules/core/src/test/java/org/apache/ignite/loadtests/cache/GridCacheDataStructuresLoadTest.java @@ -85,8 +85,7 @@ public final class GridCacheDataStructuresLoadTest extends GridCacheAbstractLoad /** Atomic long write closure. */ private final CIX1<Ignite> longWriteClos = new CIX1<Ignite>() { - @Override public void applyx(Ignite ignite) - throws IgniteCheckedException { + @Override public void applyx(Ignite ignite) { IgniteAtomicLong al = ignite.atomicLong(TEST_LONG_NAME, 0, true); for (int i = 0; i < operationsPerTx; i++) { @@ -103,8 +102,7 @@ public final class GridCacheDataStructuresLoadTest extends GridCacheAbstractLoad /** Atomic long read closure. */ private final CIX1<Ignite> longReadClos = new CIX1<Ignite>() { - @Override public void applyx(Ignite ignite) - throws IgniteCheckedException { + @Override public void applyx(Ignite ignite) { IgniteAtomicLong al = ignite.atomicLong(TEST_LONG_NAME, 0, true); for (int i = 0; i < operationsPerTx; i++) { @@ -121,8 +119,7 @@ public final class GridCacheDataStructuresLoadTest extends GridCacheAbstractLoad /** Atomic reference write closure. */ private final CIX1<Ignite> refWriteClos = new CIX1<Ignite>() { - @Override public void applyx(Ignite ignite) - throws IgniteCheckedException { + @Override public void applyx(Ignite ignite) { IgniteAtomicReference<Integer> ar = ignite.atomicReference(TEST_REF_NAME, null, true); @@ -140,8 +137,7 @@ public final class GridCacheDataStructuresLoadTest extends GridCacheAbstractLoad /** Atomic reference read closure. */ private final CIX1<Ignite> refReadClos = new CIX1<Ignite>() { - @Override public void applyx(Ignite ignite) - throws IgniteCheckedException { + @Override public void applyx(Ignite ignite) { IgniteAtomicReference<Integer> ar = ignite.atomicReference(TEST_REF_NAME, null, true); @@ -159,8 +155,7 @@ public final class GridCacheDataStructuresLoadTest extends GridCacheAbstractLoad /** Atomic sequence write closure. */ private final CIX1<Ignite> seqWriteClos = new CIX1<Ignite>() { - @Override public void applyx(Ignite ignite) - throws IgniteCheckedException { + @Override public void applyx(Ignite ignite) { IgniteAtomicSequence as = ignite.atomicSequence(TEST_SEQ_NAME, 0, true); for (int i = 0; i < operationsPerTx; i++) { @@ -177,8 +172,7 @@ public final class GridCacheDataStructuresLoadTest extends GridCacheAbstractLoad /** Atomic sequence read closure. */ private final CIX1<Ignite> seqReadClos = new CIX1<Ignite>() { - @Override public void applyx(Ignite ignite) - throws IgniteCheckedException { + @Override public void applyx(Ignite ignite) { IgniteAtomicSequence as = ignite.atomicSequence(TEST_SEQ_NAME, 0, true); for (int i = 0; i < operationsPerTx; i++) { @@ -195,8 +189,7 @@ public final class GridCacheDataStructuresLoadTest extends GridCacheAbstractLoad /** Atomic stamped write closure. */ private final CIX1<Ignite> stampWriteClos = new CIX1<Ignite>() { - @Override public void applyx(Ignite ignite) - throws IgniteCheckedException { + @Override public void applyx(Ignite ignite) { IgniteAtomicStamped<Integer, Integer> as = ignite.atomicStamped(TEST_STAMP_NAME, 0, 0, true); @@ -214,8 +207,7 @@ public final class GridCacheDataStructuresLoadTest extends GridCacheAbstractLoad /** Atomic stamped read closure. */ private final CIX1<Ignite> stampReadClos = new CIX1<Ignite>() { - @Override public void applyx(Ignite ignite) - throws IgniteCheckedException { + @Override public void applyx(Ignite ignite) { IgniteAtomicStamped<Integer, Integer> as = ignite.atomicStamped(TEST_STAMP_NAME, 0, 0, true); @@ -233,8 +225,7 @@ public final class GridCacheDataStructuresLoadTest extends GridCacheAbstractLoad /** Queue write closure. */ private final CIX1<Ignite> queueWriteClos = new CIX1<Ignite>() { - @Override public void applyx(Ignite ignite) - throws IgniteCheckedException { + @Override public void applyx(Ignite ignite) { IgniteQueue<Integer> q = ignite.queue(TEST_QUEUE_NAME, 0, colCfg); for (int i = 0; i < operationsPerTx; i++) { @@ -251,8 +242,7 @@ public final class GridCacheDataStructuresLoadTest extends GridCacheAbstractLoad /** Queue read closure. */ private final CIX1<Ignite> queueReadClos = new CIX1<Ignite>() { - @Override public void applyx(Ignite ignite) - throws IgniteCheckedException { + @Override public void applyx(Ignite ignite) { IgniteQueue<Integer> q = ignite.queue(TEST_QUEUE_NAME, 0, colCfg); for (int i = 0; i < operationsPerTx; i++) { @@ -269,8 +259,7 @@ public final class GridCacheDataStructuresLoadTest extends GridCacheAbstractLoad /** Count down latch write closure. */ private final CIX1<Ignite> latchWriteClos = new CIX1<Ignite>() { - @Override public void applyx(Ignite ignite) - throws IgniteCheckedException { + @Override public void applyx(Ignite ignite) { IgniteCountDownLatch l = ignite.countDownLatch(TEST_LATCH_NAME, LATCH_INIT_CNT, true, true); for (int i = 0; i < operationsPerTx; i++) { @@ -287,8 +276,7 @@ public final class GridCacheDataStructuresLoadTest extends GridCacheAbstractLoad /** Count down latch read closure. */ private final CIX1<Ignite> latchReadClos = new CIX1<Ignite>() { - @Override public void applyx(Ignite ignite) - throws IgniteCheckedException { + @Override public void applyx(Ignite ignite) { IgniteCountDownLatch l = ignite.countDownLatch(TEST_LATCH_NAME, LATCH_INIT_CNT, true, true); for (int i = 0; i < operationsPerTx; i++) { http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/loadtests/cache/GridCacheLoadTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/loadtests/cache/GridCacheLoadTest.java b/modules/core/src/test/java/org/apache/ignite/loadtests/cache/GridCacheLoadTest.java index 64bafc9..a33715f 100644 --- a/modules/core/src/test/java/org/apache/ignite/loadtests/cache/GridCacheLoadTest.java +++ b/modules/core/src/test/java/org/apache/ignite/loadtests/cache/GridCacheLoadTest.java @@ -47,8 +47,7 @@ public final class GridCacheLoadTest extends GridCacheAbstractLoadTest { /** Write closure. */ private final CIX1<IgniteCache<Integer, Integer>> writeClos = new CIX1<IgniteCache<Integer, Integer>>() { - @Override public void applyx(IgniteCache<Integer, Integer> cache) - throws IgniteCheckedException { + @Override public void applyx(IgniteCache<Integer, Integer> cache) { for (int i = 0; i < operationsPerTx; i++) { int kv = RAND.nextInt(KEY_RANGE); @@ -65,8 +64,7 @@ public final class GridCacheLoadTest extends GridCacheAbstractLoadTest { /** Read closure. */ private final CIX1<IgniteCache<Integer, Integer>> readClos = new CIX1<IgniteCache<Integer, Integer>>() { - @Override public void applyx(IgniteCache<Integer, Integer> cache) - throws IgniteCheckedException { + @Override public void applyx(IgniteCache<Integer, Integer> cache) { for (int i = 0; i < operationsPerTx; i++) { int k = RAND.nextInt(KEY_RANGE); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/loadtests/cache/GridCacheSwapLoadTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/loadtests/cache/GridCacheSwapLoadTest.java b/modules/core/src/test/java/org/apache/ignite/loadtests/cache/GridCacheSwapLoadTest.java index d90a3fb..19dad7f 100644 --- a/modules/core/src/test/java/org/apache/ignite/loadtests/cache/GridCacheSwapLoadTest.java +++ b/modules/core/src/test/java/org/apache/ignite/loadtests/cache/GridCacheSwapLoadTest.java @@ -88,9 +88,8 @@ public class GridCacheSwapLoadTest { /** * @param args Command line arguments. - * @throws IgniteCheckedException In case of error. */ - public static void main(String[] args) throws IgniteCheckedException { + public static void main(String[] args) { parseArgs(args); try (Ignite g = G.start("modules/core/src/test/config/spring-cache-swap.xml")) { @@ -202,7 +201,7 @@ public class GridCacheSwapLoadTest { final AtomicInteger putKey = new AtomicInteger(0); return GridTestUtils.runMultiThreadedAsync(new CAX() { - @Override public void applyx() throws IgniteCheckedException { + @Override public void applyx() { IgniteCache<Integer, Integer> cache = g.jcache(null); assert cache != null; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/loadtests/colocation/GridTestMain.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/loadtests/colocation/GridTestMain.java b/modules/core/src/test/java/org/apache/ignite/loadtests/colocation/GridTestMain.java index 0a1bf52..e8ffedf 100644 --- a/modules/core/src/test/java/org/apache/ignite/loadtests/colocation/GridTestMain.java +++ b/modules/core/src/test/java/org/apache/ignite/loadtests/colocation/GridTestMain.java @@ -162,9 +162,8 @@ public class GridTestMain { * {@link GridTestCacheStore#loadAll} method. * * @param cache Cache to load. - * @throws IgniteCheckedException If failed. */ - private static void loadFromStore(IgniteCache<GridTestKey, Long> cache) throws IgniteCheckedException { + private static void loadFromStore(IgniteCache<GridTestKey, Long> cache) { cache.loadCache(null, 0, GridTestConstants.LOAD_THREADS, GridTestConstants.ENTRY_COUNT); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/loadtests/communication/GridIoManagerBenchmark.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/loadtests/communication/GridIoManagerBenchmark.java b/modules/core/src/test/java/org/apache/ignite/loadtests/communication/GridIoManagerBenchmark.java index 9013bb8..74fdf5f 100644 --- a/modules/core/src/test/java/org/apache/ignite/loadtests/communication/GridIoManagerBenchmark.java +++ b/modules/core/src/test/java/org/apache/ignite/loadtests/communication/GridIoManagerBenchmark.java @@ -97,9 +97,8 @@ public class GridIoManagerBenchmark { /** * @param args Command line arguments. - * @throws IgniteCheckedException If failed. */ - public static void main(String[] args) throws IgniteCheckedException { + public static void main(String[] args) { int threads = args.length > 0 ? Integer.parseInt(args[0]) : DFLT_THREADS; int duration = args.length > 1 ? Integer.parseInt(args[1]) : 0; String outputFilename = args.length > 2 ? args[2] : null; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/loadtests/direct/multisplit/GridMultiSplitsRedeployLoadTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/loadtests/direct/multisplit/GridMultiSplitsRedeployLoadTest.java b/modules/core/src/test/java/org/apache/ignite/loadtests/direct/multisplit/GridMultiSplitsRedeployLoadTest.java index 7ff0ca3..3762d8a 100644 --- a/modules/core/src/test/java/org/apache/ignite/loadtests/direct/multisplit/GridMultiSplitsRedeployLoadTest.java +++ b/modules/core/src/test/java/org/apache/ignite/loadtests/direct/multisplit/GridMultiSplitsRedeployLoadTest.java @@ -115,7 +115,7 @@ public class GridMultiSplitsRedeployLoadTest extends GridCommonAbstractTest { try { deployTask(ignite); } - catch (IgniteCheckedException e) { + catch (Exception e) { error("Failed to deploy grid task.", e); fail(); @@ -139,10 +139,9 @@ public class GridMultiSplitsRedeployLoadTest extends GridCommonAbstractTest { /** * @param ignite Grid. - * @throws IgniteCheckedException If failed. */ @SuppressWarnings("unchecked") - private void deployTask(Ignite ignite) throws IgniteCheckedException { + private void deployTask(Ignite ignite) { ignite.compute().localDeployTask(GridLoadTestTask.class, GridLoadTestTask.class.getClassLoader()); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/loadtests/discovery/GridGcTimeoutTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/loadtests/discovery/GridGcTimeoutTest.java b/modules/core/src/test/java/org/apache/ignite/loadtests/discovery/GridGcTimeoutTest.java index 04bbdb1..8615e10 100644 --- a/modules/core/src/test/java/org/apache/ignite/loadtests/discovery/GridGcTimeoutTest.java +++ b/modules/core/src/test/java/org/apache/ignite/loadtests/discovery/GridGcTimeoutTest.java @@ -35,10 +35,9 @@ public class GridGcTimeoutTest { /** * @param args Args. - * @throws IgniteCheckedException If failed. */ @SuppressWarnings("InfiniteLoopStatement") - public static void main(String[] args) throws IgniteCheckedException { + public static void main(String[] args) { Ignite g = G.start(U.resolveIgniteUrl(CFG_PATH)); IgniteDataLoader<Long, String> ldr = g.dataLoader(null); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/loadtests/dsi/GridDsiPerfJob.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/loadtests/dsi/GridDsiPerfJob.java b/modules/core/src/test/java/org/apache/ignite/loadtests/dsi/GridDsiPerfJob.java index 89e2106..1a9ed47 100644 --- a/modules/core/src/test/java/org/apache/ignite/loadtests/dsi/GridDsiPerfJob.java +++ b/modules/core/src/test/java/org/apache/ignite/loadtests/dsi/GridDsiPerfJob.java @@ -232,7 +232,7 @@ public class GridDsiPerfJob extends ComputeJobAdapter { try { getId(); } - catch (IgniteCheckedException e) { + catch (Exception e) { e.printStackTrace(); } @@ -247,7 +247,7 @@ public class GridDsiPerfJob extends ComputeJobAdapter { try { ses = (GridDsiSession)get(GridDsiSession.getCacheKey(terminalId)); } - catch (IgniteCheckedException e) { + catch (Exception e) { e.printStackTrace(); } @@ -300,9 +300,8 @@ public class GridDsiPerfJob extends ComputeJobAdapter { /** * @return ID. - * @throws IgniteCheckedException If failed. */ - private long getId() throws IgniteCheckedException { + private long getId() { IgniteAtomicSequence seq = ignite.atomicSequence("ID", 0, true); return seq.incrementAndGet(); @@ -311,9 +310,8 @@ public class GridDsiPerfJob extends ComputeJobAdapter { /** * @param o Object. * @param cacheKey Key. - * @throws IgniteCheckedException If failed. */ - private void put(final Object o, Object cacheKey) throws IgniteCheckedException { + private void put(final Object o, Object cacheKey) { IgniteCache<Object, Object> cache = ignite.jcache(cacheName); assert cache != null; @@ -332,10 +330,9 @@ public class GridDsiPerfJob extends ComputeJobAdapter { /** * @param key Key. * @return Object. - * @throws IgniteCheckedException If failed. */ @SuppressWarnings("ConstantConditions") - private <T> Object get(Object key) throws IgniteCheckedException { + private <T> Object get(Object key) { return ignite.jcache(cacheName).get(key); } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/loadtests/job/GridJobExecutionSingleNodeLoadTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/loadtests/job/GridJobExecutionSingleNodeLoadTest.java b/modules/core/src/test/java/org/apache/ignite/loadtests/job/GridJobExecutionSingleNodeLoadTest.java index ecdfe8c..8c0a717 100644 --- a/modules/core/src/test/java/org/apache/ignite/loadtests/job/GridJobExecutionSingleNodeLoadTest.java +++ b/modules/core/src/test/java/org/apache/ignite/loadtests/job/GridJobExecutionSingleNodeLoadTest.java @@ -80,7 +80,7 @@ public class GridJobExecutionSingleNodeLoadTest { X.println("Warming up..."); GridLoadTestUtils.runMultithreadedInLoop(new Callable<Object>() { - @Override public Object call() throws IgniteCheckedException { + @Override public Object call() { g.compute().execute(GridJobExecutionLoadTestTask.class, null); return null; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/loadtests/mapper/GridContinuousMapperLoadTest1.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/loadtests/mapper/GridContinuousMapperLoadTest1.java b/modules/core/src/test/java/org/apache/ignite/loadtests/mapper/GridContinuousMapperLoadTest1.java index e3adec6..4e6d9b5 100644 --- a/modules/core/src/test/java/org/apache/ignite/loadtests/mapper/GridContinuousMapperLoadTest1.java +++ b/modules/core/src/test/java/org/apache/ignite/loadtests/mapper/GridContinuousMapperLoadTest1.java @@ -28,9 +28,8 @@ public class GridContinuousMapperLoadTest1 { * Main method. * * @param args Parameters. - * @throws IgniteCheckedException If failed. */ - public static void main(String[] args) throws IgniteCheckedException { + public static void main(String[] args) { try (Ignite g = G.start("examples/config/example-cache.xml")) { int max = 30000; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/loadtests/mapper/GridNodeStartup.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/loadtests/mapper/GridNodeStartup.java b/modules/core/src/test/java/org/apache/ignite/loadtests/mapper/GridNodeStartup.java index 15fdcb6..6c42130 100644 --- a/modules/core/src/test/java/org/apache/ignite/loadtests/mapper/GridNodeStartup.java +++ b/modules/core/src/test/java/org/apache/ignite/loadtests/mapper/GridNodeStartup.java @@ -36,9 +36,8 @@ public class GridNodeStartup { * Start up an empty node with specified cache configuration. * * @param args Command line arguments, none required. - * @throws IgniteCheckedException If example execution failed. */ - public static void main(String[] args) throws IgniteCheckedException { + public static void main(String[] args) { try (Ignite ignored = G.start("examples/config/example-cache.xml")) { // Wait until Ok is pressed. JOptionPane.showMessageDialog( http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/loadtests/mergesort/GridMergeSortLoadTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/loadtests/mergesort/GridMergeSortLoadTest.java b/modules/core/src/test/java/org/apache/ignite/loadtests/mergesort/GridMergeSortLoadTest.java index dceb371..9a38b06 100644 --- a/modules/core/src/test/java/org/apache/ignite/loadtests/mergesort/GridMergeSortLoadTest.java +++ b/modules/core/src/test/java/org/apache/ignite/loadtests/mergesort/GridMergeSortLoadTest.java @@ -106,9 +106,8 @@ public class GridMergeSortLoadTest { * @param g Grid to run sorting on. * @param size Size of the generated array, which we sort. * @return Sort execution time in milliseconds. - * @throws IgniteCheckedException If failed. */ - private static long sort(Ignite g, int size) throws IgniteCheckedException { + private static long sort(Ignite g, int size) { int[] bigArr = generateRandomArray(size); X.println("Array is generated."); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/loadtests/streamer/GridStreamerIndexLoadTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/loadtests/streamer/GridStreamerIndexLoadTest.java b/modules/core/src/test/java/org/apache/ignite/loadtests/streamer/GridStreamerIndexLoadTest.java index d7ce854..9c34085 100644 --- a/modules/core/src/test/java/org/apache/ignite/loadtests/streamer/GridStreamerIndexLoadTest.java +++ b/modules/core/src/test/java/org/apache/ignite/loadtests/streamer/GridStreamerIndexLoadTest.java @@ -115,7 +115,7 @@ public class GridStreamerIndexLoadTest { final AtomicLong enqueueCntr = new AtomicLong(); IgniteInternalFuture<Long> enqueueFut = runMultiThreadedAsync(new CAX() { - @Override public void applyx() throws IgniteCheckedException { + @Override public void applyx() { Random rnd = new Random(); while (!Thread.currentThread().isInterrupted()) { @@ -129,7 +129,7 @@ public class GridStreamerIndexLoadTest { final AtomicLong evictCntr = new AtomicLong(); IgniteInternalFuture<Long> evictFut = runMultiThreadedAsync(new CAX() { - @Override public void applyx() throws IgniteCheckedException { + @Override public void applyx() { while (!Thread.currentThread().isInterrupted()) { win.pollEvicted(); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/loadtests/swap/GridSwapEvictAllBenchmark.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/loadtests/swap/GridSwapEvictAllBenchmark.java b/modules/core/src/test/java/org/apache/ignite/loadtests/swap/GridSwapEvictAllBenchmark.java index 0a61f38..1ab284f 100644 --- a/modules/core/src/test/java/org/apache/ignite/loadtests/swap/GridSwapEvictAllBenchmark.java +++ b/modules/core/src/test/java/org/apache/ignite/loadtests/swap/GridSwapEvictAllBenchmark.java @@ -247,10 +247,9 @@ public class GridSwapEvictAllBenchmark { /** * @param store Cache store. * @return Started grid. - * @throws IgniteCheckedException If failed. */ @SuppressWarnings("unchecked") - private static Ignite start(CacheStore<Long, String> store) throws IgniteCheckedException { + private static Ignite start(CacheStore<Long, String> store) { IgniteConfiguration cfg = new IgniteConfiguration(); cfg.setLocalHost("127.0.0.1"); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/session/GridSessionFutureWaitJobAttributeSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/session/GridSessionFutureWaitJobAttributeSelfTest.java b/modules/core/src/test/java/org/apache/ignite/session/GridSessionFutureWaitJobAttributeSelfTest.java index 02c9119..5cf489a 100644 --- a/modules/core/src/test/java/org/apache/ignite/session/GridSessionFutureWaitJobAttributeSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/session/GridSessionFutureWaitJobAttributeSelfTest.java @@ -105,9 +105,8 @@ public class GridSessionFutureWaitJobAttributeSelfTest extends GridCommonAbstrac /** * @param num Number. * @throws InterruptedException if failed. - * @throws IgniteCheckedException if failed. */ - private void checkTask(int num) throws InterruptedException, IgniteCheckedException { + private void checkTask(int num) throws InterruptedException { Ignite ignite = G.ignite(getTestGridName()); IgniteCompute comp = ignite.compute().withAsync(); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/session/GridSessionSetTaskAttributeSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/session/GridSessionSetTaskAttributeSelfTest.java b/modules/core/src/test/java/org/apache/ignite/session/GridSessionSetTaskAttributeSelfTest.java index 0a21397..5eb5d7a 100644 --- a/modules/core/src/test/java/org/apache/ignite/session/GridSessionSetTaskAttributeSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/session/GridSessionSetTaskAttributeSelfTest.java @@ -90,9 +90,8 @@ public class GridSessionSetTaskAttributeSelfTest extends GridCommonAbstractTest /** * @param num Number. - * @throws IgniteCheckedException if failed. */ - private void checkTask(int num) throws IgniteCheckedException { + private void checkTask(int num) { Ignite ignite = G.ignite(getTestGridName()); IgniteCompute comp = ignite.compute().withAsync(); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/session/GridSessionTaskWaitJobAttributeSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/session/GridSessionTaskWaitJobAttributeSelfTest.java b/modules/core/src/test/java/org/apache/ignite/session/GridSessionTaskWaitJobAttributeSelfTest.java index 5d5cb72..8a166d6 100644 --- a/modules/core/src/test/java/org/apache/ignite/session/GridSessionTaskWaitJobAttributeSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/session/GridSessionTaskWaitJobAttributeSelfTest.java @@ -90,9 +90,8 @@ public class GridSessionTaskWaitJobAttributeSelfTest extends GridCommonAbstractT /** * @param num Number. - * @throws IgniteCheckedException if failed. */ - private void checkTask(int num) throws IgniteCheckedException { + private void checkTask(int num) { Ignite ignite = G.ignite(getTestGridName()); IgniteCompute comp = ignite.compute().withAsync(); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/spi/loadbalancing/roundrobin/GridRoundRobinTestUtils.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/spi/loadbalancing/roundrobin/GridRoundRobinTestUtils.java b/modules/core/src/test/java/org/apache/ignite/spi/loadbalancing/roundrobin/GridRoundRobinTestUtils.java index e601906..e574e53 100644 --- a/modules/core/src/test/java/org/apache/ignite/spi/loadbalancing/roundrobin/GridRoundRobinTestUtils.java +++ b/modules/core/src/test/java/org/apache/ignite/spi/loadbalancing/roundrobin/GridRoundRobinTestUtils.java @@ -36,10 +36,9 @@ class GridRoundRobinTestUtils { * @param allNodes Topology nodes. * @param orderedNodes Balancing nodes. * @param ses Task session. - * @throws IgniteCheckedException If balancer failed. */ static void checkCyclicBalancing(RoundRobinLoadBalancingSpi spi, List<ClusterNode> allNodes, - List<UUID> orderedNodes, ComputeTaskSession ses) throws IgniteCheckedException { + List<UUID> orderedNodes, ComputeTaskSession ses) { ClusterNode firstNode = spi.getBalancedNode(ses, allNodes, new GridTestJob()); @@ -64,10 +63,9 @@ class GridRoundRobinTestUtils { * @param orderedNodes Balancing nodes. * @param ses1 First task session. * @param ses2 Second task session. - * @throws IgniteCheckedException If balancer failed. */ static void checkCyclicBalancing(RoundRobinLoadBalancingSpi spi, List<ClusterNode> allNodes, - List<UUID> orderedNodes, ComputeTaskSession ses1, ComputeTaskSession ses2) throws IgniteCheckedException { + List<UUID> orderedNodes, ComputeTaskSession ses1, ComputeTaskSession ses2) { ClusterNode firstNode = spi.getBalancedNode(ses1, allNodes, new GridTestJob()); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/streamer/index/GridStreamerIndexSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/streamer/index/GridStreamerIndexSelfTest.java b/modules/core/src/test/java/org/apache/ignite/streamer/index/GridStreamerIndexSelfTest.java index 3cb04f9..869dd94 100644 --- a/modules/core/src/test/java/org/apache/ignite/streamer/index/GridStreamerIndexSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/streamer/index/GridStreamerIndexSelfTest.java @@ -174,9 +174,8 @@ public class GridStreamerIndexSelfTest extends GridCommonAbstractTest { * it discards event "A" and accepts event "B". * * @param updater Index updater. - * @throws IgniteCheckedException If failed. */ - private void checkIndexUpdater(StreamerIndexUpdater<String, String, Integer> updater) throws IgniteCheckedException { + private void checkIndexUpdater(StreamerIndexUpdater<String, String, Integer> updater) { List<StreamerIndexProvider<String, String, Integer>> idxps = Arrays.asList( indexProvider(true, "tree", updater, StreamerIndexPolicy.EVENT_TRACKING_ON, false), indexProvider(false, "hash", updater, StreamerIndexPolicy.EVENT_TRACKING_ON, false)); @@ -257,7 +256,7 @@ public class GridStreamerIndexSelfTest extends GridCommonAbstractTest { // Submit the same event in multiple threads. runMultiThreaded(new CAX() { - @Override public void applyx() throws IgniteCheckedException { + @Override public void applyx() { try { win.enqueue(evt); } @@ -302,7 +301,7 @@ public class GridStreamerIndexSelfTest extends GridCommonAbstractTest { // These threads poll evicted events from the window if it doesn't break // the test invariant. pollFut = runMultiThreadedAsync(new CAX() { - @Override public void applyx() throws IgniteCheckedException { + @Override public void applyx() { try { while (!Thread.currentThread().isInterrupted()) { StreamerIndex<String, String, Integer> idx = win.index("idx"); @@ -332,7 +331,7 @@ public class GridStreamerIndexSelfTest extends GridCommonAbstractTest { // sorted by value and the value is a number of repeated events, so, this // should be invariant. IgniteInternalFuture<Long> fut1 = runMultiThreadedAsync(new CAX() { - @Override public void applyx() throws IgniteCheckedException { + @Override public void applyx() { final String evt = Thread.currentThread().getName(); int cntr = 1; @@ -359,7 +358,7 @@ public class GridStreamerIndexSelfTest extends GridCommonAbstractTest { // This thread generates a set of single non-repeating events from 0 to iters. IgniteInternalFuture<Long> fut2 = runMultiThreadedAsync(new CAX() { - @Override public void applyx() throws IgniteCheckedException { + @Override public void applyx() { for (int i = 0; i < iters && !Thread.currentThread().isInterrupted(); i++) win.enqueue(String.valueOf(i)); } @@ -376,9 +375,8 @@ public class GridStreamerIndexSelfTest extends GridCommonAbstractTest { /** * @param idx Index. - * @throws IgniteCheckedException If failed. */ - private void checkNonUniqueIndex(StreamerIndexProvider<String, String, Integer> idx) throws IgniteCheckedException { + private void checkNonUniqueIndex(StreamerIndexProvider<String, String, Integer> idx) { assert !idx.isUnique(); StreamerBoundedSizeWindow<String> win = new StreamerBoundedSizeWindow<>(); @@ -511,9 +509,8 @@ public class GridStreamerIndexSelfTest extends GridCommonAbstractTest { /** * @param idx Index. - * @throws IgniteCheckedException If failed. */ - private void checkUniqueIndex(StreamerIndexProvider<String, String, String> idx) throws IgniteCheckedException { + private void checkUniqueIndex(StreamerIndexProvider<String, String, String> idx) { assert idx.isUnique(); StreamerBoundedSizeWindow<String> win = new StreamerBoundedSizeWindow<>(); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/streamer/window/GridStreamerWindowSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/streamer/window/GridStreamerWindowSelfTest.java b/modules/core/src/test/java/org/apache/ignite/streamer/window/GridStreamerWindowSelfTest.java index 6379d74..27ce309 100644 --- a/modules/core/src/test/java/org/apache/ignite/streamer/window/GridStreamerWindowSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/streamer/window/GridStreamerWindowSelfTest.java @@ -757,9 +757,8 @@ public class GridStreamerWindowSelfTest extends GridCommonAbstractTest { * * @param win Window to check. * @param maxSize Max window size. - * @throws IgniteCheckedException If failed. */ - private void finalChecks(StreamerWindow<Integer> win, int maxSize) throws IgniteCheckedException { + private void finalChecks(StreamerWindow<Integer> win, int maxSize) { int evictQueueSize = win.evictionQueueSize(); info("Eviction queue size for final checks: " + evictQueueSize); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/testframework/junits/cache/GridAbstractCacheStoreSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/testframework/junits/cache/GridAbstractCacheStoreSelfTest.java b/modules/core/src/test/java/org/apache/ignite/testframework/junits/cache/GridAbstractCacheStoreSelfTest.java index ccb8b7e..372682a 100644 --- a/modules/core/src/test/java/org/apache/ignite/testframework/junits/cache/GridAbstractCacheStoreSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/testframework/junits/cache/GridAbstractCacheStoreSelfTest.java @@ -198,9 +198,8 @@ public abstract class GridAbstractCacheStoreSelfTest<T extends CacheStore<Object /** * @param tx Transaction. * @param commit Commit. - * @throws IgniteCheckedException If failed. */ - private void doTestAllOps(@Nullable Transaction tx, boolean commit) throws IgniteCheckedException { + private void doTestAllOps(@Nullable Transaction tx, boolean commit) { try { ses.newSession(tx); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/hadoop/src/main/java/org/apache/ignite/internal/igfs/hadoop/IgfsHadoopWrapper.java ---------------------------------------------------------------------- diff --git a/modules/hadoop/src/main/java/org/apache/ignite/internal/igfs/hadoop/IgfsHadoopWrapper.java b/modules/hadoop/src/main/java/org/apache/ignite/internal/igfs/hadoop/IgfsHadoopWrapper.java index 3ac2d5a..5586e72 100644 --- a/modules/hadoop/src/main/java/org/apache/ignite/internal/igfs/hadoop/IgfsHadoopWrapper.java +++ b/modules/hadoop/src/main/java/org/apache/ignite/internal/igfs/hadoop/IgfsHadoopWrapper.java @@ -80,7 +80,7 @@ public class IgfsHadoopWrapper implements IgfsHadoop { @Override public IgfsHandshakeResponse handshake(String logDir) throws IOException { return withReconnectHandling(new FileSystemClosure<IgfsHandshakeResponse>() { @Override public IgfsHandshakeResponse apply(IgfsHadoopEx hadoop, - IgfsHandshakeResponse hndResp) throws IgniteCheckedException, IOException { + IgfsHandshakeResponse hndResp) { return hndResp; } }); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/GridHadoopSetup.java ---------------------------------------------------------------------- diff --git a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/GridHadoopSetup.java b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/GridHadoopSetup.java index fc3dadc..0f09600 100644 --- a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/GridHadoopSetup.java +++ b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/GridHadoopSetup.java @@ -45,9 +45,8 @@ public class GridHadoopSetup { /** * The main method. * @param ignore Params. - * @throws IOException If fails. */ - public static void main(String[] ignore) throws IOException { + public static void main(String[] ignore) { X.println( " __________ ________________ ", " / _/ ___/ |/ / _/_ __/ __/ ", http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/planner/GridHadoopDefaultMapReducePlanner.java ---------------------------------------------------------------------- diff --git a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/planner/GridHadoopDefaultMapReducePlanner.java b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/planner/GridHadoopDefaultMapReducePlanner.java index 8e85cc1..342cbab 100644 --- a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/planner/GridHadoopDefaultMapReducePlanner.java +++ b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/planner/GridHadoopDefaultMapReducePlanner.java @@ -291,10 +291,9 @@ public class GridHadoopDefaultMapReducePlanner implements GridHadoopMapReducePla * @param mappers Mappers map. * @param reducerCnt Reducers count. * @return Reducers map. - * @throws IgniteCheckedException If failed. */ private Map<UUID, int[]> reducers(Collection<ClusterNode> top, - Map<UUID, Collection<GridHadoopInputSplit>> mappers, int reducerCnt) throws IgniteCheckedException { + Map<UUID, Collection<GridHadoopInputSplit>> mappers, int reducerCnt) { // Determine initial node weights. int totalWeight = 0; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/taskexecutor/GridHadoopExecutorService.java ---------------------------------------------------------------------- diff --git a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/taskexecutor/GridHadoopExecutorService.java b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/taskexecutor/GridHadoopExecutorService.java index b26eec5..9ec637b 100644 --- a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/taskexecutor/GridHadoopExecutorService.java +++ b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/taskexecutor/GridHadoopExecutorService.java @@ -179,7 +179,7 @@ public class GridHadoopExecutorService { workerName = task.toString(); GridWorker w = new GridWorker(gridName, workerName, log, lsnr) { - @Override protected void body() throws InterruptedException, IgniteInterruptedCheckedException { + @Override protected void body() { try { task.call(); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/v2/GridHadoopSplitWrapper.java ---------------------------------------------------------------------- diff --git a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/v2/GridHadoopSplitWrapper.java b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/v2/GridHadoopSplitWrapper.java index 791f90b..57edfa9 100644 --- a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/v2/GridHadoopSplitWrapper.java +++ b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/v2/GridHadoopSplitWrapper.java @@ -54,9 +54,8 @@ public class GridHadoopSplitWrapper extends GridHadoopInputSplit { * @param clsName Class name. * @param bytes Serialized class. * @param hosts Hosts where split is located. - * @throws IOException If failed. */ - public GridHadoopSplitWrapper(int id, String clsName, byte[] bytes, String[] hosts) throws IOException { + public GridHadoopSplitWrapper(int id, String clsName, byte[] bytes, String[] hosts) { assert hosts != null; assert clsName != null; assert bytes != null; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/GridHadoopGroupingTest.java ---------------------------------------------------------------------- diff --git a/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/GridHadoopGroupingTest.java b/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/GridHadoopGroupingTest.java index 05ae708..7f56995 100644 --- a/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/GridHadoopGroupingTest.java +++ b/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/GridHadoopGroupingTest.java @@ -228,7 +228,7 @@ public class GridHadoopGroupingTest extends GridHadoopAbstractSelfTest { /** */ Text val = new Text(); - @Override public void initialize(InputSplit split, TaskAttemptContext context) throws IOException, InterruptedException { + @Override public void initialize(InputSplit split, TaskAttemptContext context) { // No-op. } @@ -236,14 +236,14 @@ public class GridHadoopGroupingTest extends GridHadoopAbstractSelfTest { return cnt++ < split.getLength(); } - @Override public YearTemperature getCurrentKey() throws IOException, InterruptedException { + @Override public YearTemperature getCurrentKey() { key.year = 1990 + rnd.nextInt(10); key.temperature = 10 + rnd.nextInt(20); return key; } - @Override public Text getCurrentValue() throws IOException, InterruptedException { + @Override public Text getCurrentValue() { UUID id = UUID.randomUUID(); assertTrue(vals.add(id)); @@ -253,11 +253,11 @@ public class GridHadoopGroupingTest extends GridHadoopAbstractSelfTest { return val; } - @Override public float getProgress() throws IOException, InterruptedException { + @Override public float getProgress() { return 0; } - @Override public void close() throws IOException { + @Override public void close() { // No-op. } }; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/GridHadoopJobTrackerSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/GridHadoopJobTrackerSelfTest.java b/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/GridHadoopJobTrackerSelfTest.java index b779e93..3aa74d0 100644 --- a/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/GridHadoopJobTrackerSelfTest.java +++ b/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/GridHadoopJobTrackerSelfTest.java @@ -272,7 +272,7 @@ public class GridHadoopJobTrackerSelfTest extends GridHadoopAbstractSelfTest { return null; } - @Override public float getProgress() throws IOException, InterruptedException { + @Override public float getProgress() { return 0; } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/GridHadoopSortingTest.java ---------------------------------------------------------------------- diff --git a/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/GridHadoopSortingTest.java b/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/GridHadoopSortingTest.java index b9ccb84..3a2c397 100644 --- a/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/GridHadoopSortingTest.java +++ b/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/GridHadoopSortingTest.java @@ -182,8 +182,7 @@ public class GridHadoopSortingTest extends GridHadoopAbstractSelfTest { /** */ Text txt = new Text(); - @Override public void initialize(InputSplit split, TaskAttemptContext ctx) throws IOException, - InterruptedException { + @Override public void initialize(InputSplit split, TaskAttemptContext ctx) { // No-op. } @@ -191,7 +190,7 @@ public class GridHadoopSortingTest extends GridHadoopAbstractSelfTest { return ++cnt <= split.getLength(); } - @Override public Text getCurrentKey() throws IOException, InterruptedException { + @Override public Text getCurrentKey() { txt.set(UUID.randomUUID().toString()); // X.printerrln("___ read: " + txt); @@ -199,7 +198,7 @@ public class GridHadoopSortingTest extends GridHadoopAbstractSelfTest { return txt; } - @Override public NullWritable getCurrentValue() throws IOException, InterruptedException { + @Override public NullWritable getCurrentValue() { return NullWritable.get(); } @@ -207,7 +206,7 @@ public class GridHadoopSortingTest extends GridHadoopAbstractSelfTest { return (float)cnt / split.getLength(); } - @Override public void close() throws IOException { + @Override public void close() { // No-op. } }; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/GridHadoopStartup.java ---------------------------------------------------------------------- diff --git a/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/GridHadoopStartup.java b/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/GridHadoopStartup.java index ceb5088..6cc7635 100644 --- a/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/GridHadoopStartup.java +++ b/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/GridHadoopStartup.java @@ -29,7 +29,7 @@ public class GridHadoopStartup { /** * @param args Arguments. */ - public static void main(String[] args) throws IgniteCheckedException { + public static void main(String[] args) { G.start("config/hadoop/default-config.xml"); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/hadoop/src/test/java/org/apache/ignite/loadtests/igfs/IgfsNodeStartup.java ---------------------------------------------------------------------- diff --git a/modules/hadoop/src/test/java/org/apache/ignite/loadtests/igfs/IgfsNodeStartup.java b/modules/hadoop/src/test/java/org/apache/ignite/loadtests/igfs/IgfsNodeStartup.java index 8f67bcf..e4cffbe 100644 --- a/modules/hadoop/src/test/java/org/apache/ignite/loadtests/igfs/IgfsNodeStartup.java +++ b/modules/hadoop/src/test/java/org/apache/ignite/loadtests/igfs/IgfsNodeStartup.java @@ -30,9 +30,8 @@ public class IgfsNodeStartup { * Start up an empty node with specified cache configuration. * * @param args Command line arguments, none required. - * @throws IgniteCheckedException If example execution failed. */ - public static void main(String[] args) throws IgniteCheckedException { + public static void main(String[] args) { try (Ignite ignored = G.start("config/hadoop/default-config.xml")) { // Wait until Ok is pressed. JOptionPane.showMessageDialog( http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/hibernate/src/main/java/org/apache/ignite/cache/hibernate/GridHibernateReadWriteAccessStrategy.java ---------------------------------------------------------------------- diff --git a/modules/hibernate/src/main/java/org/apache/ignite/cache/hibernate/GridHibernateReadWriteAccessStrategy.java b/modules/hibernate/src/main/java/org/apache/ignite/cache/hibernate/GridHibernateReadWriteAccessStrategy.java index 4694d03..ce5c76b 100644 --- a/modules/hibernate/src/main/java/org/apache/ignite/cache/hibernate/GridHibernateReadWriteAccessStrategy.java +++ b/modules/hibernate/src/main/java/org/apache/ignite/cache/hibernate/GridHibernateReadWriteAccessStrategy.java @@ -125,7 +125,7 @@ public class GridHibernateReadWriteAccessStrategy extends GridHibernateAccessStr if (ctx != null) unlock(ctx, key); } - catch (IgniteCheckedException e) { + catch (IgniteException e) { rollbackCurrentTx(); throw new CacheException(e); @@ -197,9 +197,8 @@ public class GridHibernateReadWriteAccessStrategy extends GridHibernateAccessStr * * @param ctx Transaction context. * @param key Key. - * @throws IgniteCheckedException If failed. */ - private void unlock(TxContext ctx, Object key) throws IgniteCheckedException { + private void unlock(TxContext ctx, Object key) { if (ctx.unlocked(key)) { // Finish transaction if last key is unlocked. txCtx.remove(); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheCrossCacheQuerySelfTest.java ---------------------------------------------------------------------- diff --git a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheCrossCacheQuerySelfTest.java b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheCrossCacheQuerySelfTest.java index ff22703..aa408f4 100644 --- a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheCrossCacheQuerySelfTest.java +++ b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheCrossCacheQuerySelfTest.java @@ -191,7 +191,7 @@ public class GridCacheCrossCacheQuerySelfTest extends GridCommonAbstractTest { /** * @throws IgniteCheckedException If failed. */ - private void fillCaches() throws IgniteCheckedException, InterruptedException { + private void fillCaches() throws IgniteCheckedException { int idGen = 0; GridCache<Integer, Object> dimCache = ((IgniteKernal)ignite).cache("replicated"); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheCrossCacheQuerySelfTestNewApi.java ---------------------------------------------------------------------- diff --git a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheCrossCacheQuerySelfTestNewApi.java b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheCrossCacheQuerySelfTestNewApi.java index 1e07bde..6de54ec 100644 --- a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheCrossCacheQuerySelfTestNewApi.java +++ b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheCrossCacheQuerySelfTestNewApi.java @@ -162,7 +162,7 @@ public class GridCacheCrossCacheQuerySelfTestNewApi extends GridCommonAbstractTe /** * @throws IgniteCheckedException If failed. */ - private void fillCaches() throws IgniteCheckedException, InterruptedException { + private void fillCaches() throws IgniteCheckedException { int idGen = 0; GridCache<Integer, Object> dimCache = ((IgniteKernal)ignite).cache("replicated"); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/spring/src/test/java/org/apache/ignite/p2p/GridP2PUserVersionChangeSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/spring/src/test/java/org/apache/ignite/p2p/GridP2PUserVersionChangeSelfTest.java b/modules/spring/src/test/java/org/apache/ignite/p2p/GridP2PUserVersionChangeSelfTest.java index 8292223..abb3422 100644 --- a/modules/spring/src/test/java/org/apache/ignite/p2p/GridP2PUserVersionChangeSelfTest.java +++ b/modules/spring/src/test/java/org/apache/ignite/p2p/GridP2PUserVersionChangeSelfTest.java @@ -304,7 +304,7 @@ public class GridP2PUserVersionChangeSelfTest extends GridCommonAbstractTest { // cache is REPLICATED. This happens asynchronously, we // need to use condition wait. assert GridTestUtils.waitForCondition(new PAX() { - @Override public boolean applyx() throws IgniteCheckedException { + @Override public boolean applyx() { return cache2.get(1L) != null; } }, getConditionTimeout()); @@ -326,7 +326,7 @@ public class GridP2PUserVersionChangeSelfTest extends GridCommonAbstractTest { // At this point, old version of test resource should be undeployed // and removed from cache asynchronously. assert GridTestUtils.waitForCondition(new PAX() { - @Override public boolean applyx() throws IgniteCheckedException { + @Override public boolean applyx() { return cache2.get(1L) == null; } }, getConditionTimeout()) : "2nd condition failed [entries1=" + toSet(cache1.iterator()) + http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/ssh/src/test/java/org/apache/ignite/internal/IgniteProjectionStartStopRestartSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/ssh/src/test/java/org/apache/ignite/internal/IgniteProjectionStartStopRestartSelfTest.java b/modules/ssh/src/test/java/org/apache/ignite/internal/IgniteProjectionStartStopRestartSelfTest.java index babdbbb..d4c5fc5 100644 --- a/modules/ssh/src/test/java/org/apache/ignite/internal/IgniteProjectionStartStopRestartSelfTest.java +++ b/modules/ssh/src/test/java/org/apache/ignite/internal/IgniteProjectionStartStopRestartSelfTest.java @@ -1015,14 +1015,13 @@ public class IgniteProjectionStartStopRestartSelfTest extends GridCommonAbstract * @param timeout Timeout. * @param maxConn Maximum connections. * @return Results collection. - * @throws IgniteCheckedException If failed. */ private Collection<GridTuple3<String, Boolean, String>> startNodes(IgniteCluster cluster, Collection<Map<String, Object>> hosts, @Nullable Map<String, Object> dflts, boolean restart, int timeout, - int maxConn) throws IgniteCheckedException { + int maxConn) { cluster = cluster.withAsync(); assertNull(cluster.startNodes(hosts, dflts, restart, timeout, maxConn));
