ignite-272 review
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/7423b7cb Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/7423b7cb Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/7423b7cb Branch: refs/heads/ignite-sql-tests Commit: 7423b7cb3b27e68abcb03103a9a998d7e483cf74 Parents: 7bf5403 Author: Yakov Zhdanov <yzhda...@gridgain.com> Authored: Wed Feb 25 21:41:37 2015 +0300 Committer: Yakov Zhdanov <yzhda...@gridgain.com> Committed: Wed Feb 25 21:41:38 2015 +0300 ---------------------------------------------------------------------- .../IgniteCountDownLatchExample.java | 3 +- .../MessagingPingPongListenActorExample.java | 3 +- .../checkpoint/s3/S3CheckpointSpiSelfTest.java | 10 +++--- .../internal/client/ClientStartNodeTask.java | 5 ++- .../processors/rest/RestProcessorTest.java | 8 ++--- .../processors/cache/GridCacheSwapManager.java | 4 +-- .../query/GridCacheDistributedQueryManager.java | 4 +-- .../cache/query/GridCacheQueryManager.java | 2 +- .../dataload/GridDataLoaderProcessor.java | 2 +- .../datastructures/DataStructuresProcessor.java | 2 +- .../processors/igfs/IgfsDataManager.java | 4 +-- .../internal/processors/igfs/IgfsImpl.java | 6 ++-- .../processors/igfs/IgfsOutputStreamImpl.java | 4 +-- .../internal/processors/job/GridJobWorker.java | 2 +- .../processors/task/GridTaskWorker.java | 4 +-- .../ignite/internal/util/IgniteUtils.java | 4 +-- .../apache/ignite/internal/util/typedef/X.java | 3 +- .../ignite/spi/IgniteSpiThreadFactory.java | 2 +- .../spi/discovery/tcp/TcpDiscoverySpi.java | 17 ++++----- .../spi/swapspace/file/FileSwapSpaceSpi.java | 2 +- .../internal/GridEventStorageSelfTest.java | 3 +- .../GridJobMasterLeaveAwareSelfTest.java | 24 ++++++------- .../internal/GridMultipleJobsSelfTest.java | 2 +- .../GridTaskContinuousMapperSelfTest.java | 3 +- .../GridTaskExecutionContextSelfTest.java | 2 +- .../GridCheckpointManagerAbstractSelfTest.java | 20 +++++------ .../cache/GridCacheAbstractFullApiSelfTest.java | 2 +- .../GridCacheConcurrentTxMultiNodeTest.java | 11 +++--- .../cache/GridCachePutAllFailoverSelfTest.java | 5 +-- .../cache/IgniteTxMultiNodeAbstractTest.java | 33 +++++------------- ...cheAtomicReferenceMultiNodeAbstractTest.java | 12 +++---- .../GridCacheMultiNodeDataStructureTest.java | 3 +- ...dCacheSequenceMultiNodeAbstractSelfTest.java | 2 +- ...titionedAtomicSequenceMultiThreadedTest.java | 16 ++++----- ...dCachePartitionedQueueEntryMoveSelfTest.java | 2 +- .../GridCacheAbstractJobExecutionTest.java | 2 +- .../distributed/GridCacheEventAbstractTest.java | 4 +-- .../dht/GridCacheDhtInternalEntrySelfTest.java | 6 ++-- .../dht/GridCacheDhtMultiBackupTest.java | 2 +- ...idCachePartitionedHitsAndMissesSelfTest.java | 3 +- ...ePartitionedMultiThreadedPutGetSelfTest.java | 2 +- .../GridCacheRandomEvictionPolicySelfTest.java | 2 +- .../closure/GridClosureProcessorSelfTest.java | 14 +++----- .../processors/igfs/IgfsAbstractSelfTest.java | 5 ++- .../processors/igfs/IgfsProcessorSelfTest.java | 3 +- .../streamer/GridStreamerEvictionSelfTest.java | 2 +- .../streamer/GridStreamerSelfTest.java | 2 +- .../cache/GridCacheDataStructuresLoadTest.java | 36 +++++++------------- .../loadtests/cache/GridCacheLoadTest.java | 6 ++-- .../loadtests/cache/GridCacheSwapLoadTest.java | 5 ++- .../loadtests/colocation/GridTestMain.java | 3 +- .../communication/GridIoManagerBenchmark.java | 3 +- .../GridMultiSplitsRedeployLoadTest.java | 5 ++- .../loadtests/discovery/GridGcTimeoutTest.java | 3 +- .../ignite/loadtests/dsi/GridDsiPerfJob.java | 13 +++---- .../job/GridJobExecutionSingleNodeLoadTest.java | 2 +- .../mapper/GridContinuousMapperLoadTest1.java | 3 +- .../loadtests/mapper/GridNodeStartup.java | 3 +- .../mergesort/GridMergeSortLoadTest.java | 3 +- .../streamer/GridStreamerIndexLoadTest.java | 4 +-- .../swap/GridSwapEvictAllBenchmark.java | 3 +- ...idSessionFutureWaitJobAttributeSelfTest.java | 3 +- .../GridSessionSetTaskAttributeSelfTest.java | 3 +- ...GridSessionTaskWaitJobAttributeSelfTest.java | 3 +- .../roundrobin/GridRoundRobinTestUtils.java | 6 ++-- .../index/GridStreamerIndexSelfTest.java | 17 ++++----- .../window/GridStreamerWindowSelfTest.java | 3 +- .../cache/GridAbstractCacheStoreSelfTest.java | 3 +- .../internal/igfs/hadoop/IgfsHadoopWrapper.java | 2 +- .../processors/hadoop/GridHadoopSetup.java | 3 +- .../GridHadoopDefaultMapReducePlanner.java | 3 +- .../taskexecutor/GridHadoopExecutorService.java | 2 +- .../hadoop/v2/GridHadoopSplitWrapper.java | 3 +- .../hadoop/GridHadoopGroupingTest.java | 10 +++--- .../hadoop/GridHadoopJobTrackerSelfTest.java | 2 +- .../hadoop/GridHadoopSortingTest.java | 9 +++-- .../processors/hadoop/GridHadoopStartup.java | 2 +- .../ignite/loadtests/igfs/IgfsNodeStartup.java | 3 +- .../GridHibernateReadWriteAccessStrategy.java | 5 ++- .../cache/GridCacheCrossCacheQuerySelfTest.java | 2 +- .../GridCacheCrossCacheQuerySelfTestNewApi.java | 2 +- .../p2p/GridP2PUserVersionChangeSelfTest.java | 4 +-- ...gniteProjectionStartStopRestartSelfTest.java | 3 +- 83 files changed, 182 insertions(+), 281 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteCountDownLatchExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteCountDownLatchExample.java b/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteCountDownLatchExample.java index 8cca611..dc5f608 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteCountDownLatchExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteCountDownLatchExample.java @@ -40,9 +40,8 @@ public class IgniteCountDownLatchExample { * Executes example. * * @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 ignite = Ignition.start("examples/config/example-cache.xml")) { System.out.println(); System.out.println(">>> Cache atomic countdown latch example started."); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/examples/src/main/java/org/apache/ignite/examples/messaging/MessagingPingPongListenActorExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/messaging/MessagingPingPongListenActorExample.java b/examples/src/main/java/org/apache/ignite/examples/messaging/MessagingPingPongListenActorExample.java index b498609..feeb56a 100644 --- a/examples/src/main/java/org/apache/ignite/examples/messaging/MessagingPingPongListenActorExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/messaging/MessagingPingPongListenActorExample.java @@ -41,9 +41,8 @@ public class MessagingPingPongListenActorExample { * Executes example. * * @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) { // Game is played over the default ignite. try (Ignite ignite = Ignition.start("examples/config/example-compute.xml")) { if (!ExamplesUtils.checkMinTopologySize(ignite.cluster(), 2)) http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/aws/src/test/java/org/apache/ignite/spi/checkpoint/s3/S3CheckpointSpiSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/aws/src/test/java/org/apache/ignite/spi/checkpoint/s3/S3CheckpointSpiSelfTest.java b/modules/aws/src/test/java/org/apache/ignite/spi/checkpoint/s3/S3CheckpointSpiSelfTest.java index 9010f62..c257f16 100644 --- a/modules/aws/src/test/java/org/apache/ignite/spi/checkpoint/s3/S3CheckpointSpiSelfTest.java +++ b/modules/aws/src/test/java/org/apache/ignite/spi/checkpoint/s3/S3CheckpointSpiSelfTest.java @@ -100,7 +100,7 @@ public class S3CheckpointSpiSelfTest extends GridSpiAbstractTest<S3CheckpointSpi final String key = KEY_PREFIX + i; assertWithRetries(new GridAbsClosureX() { - @Override public void applyx() throws IgniteCheckedException { + @Override public void applyx() { assertNotNull("Missing checkpoint: " + key, getSpi().loadCheckpoint(key)); } @@ -133,7 +133,7 @@ public class S3CheckpointSpiSelfTest extends GridSpiAbstractTest<S3CheckpointSpi final String key = KEY_PREFIX + i; assertWithRetries(new GridAbsClosureX() { - @Override public void applyx() throws IgniteCheckedException { + @Override public void applyx() { assertNull(getSpi().loadCheckpoint(key)); } }); @@ -159,7 +159,7 @@ public class S3CheckpointSpiSelfTest extends GridSpiAbstractTest<S3CheckpointSpi final String key = KEY_PREFIX + i; assertWithRetries(new GridAbsClosureX() { - @Override public void applyx() throws IgniteCheckedException { + @Override public void applyx() { assertNull("Checkpoint state should not be loaded with key: " + key, getSpi().loadCheckpoint(key)); } @@ -181,7 +181,7 @@ public class S3CheckpointSpiSelfTest extends GridSpiAbstractTest<S3CheckpointSpi getSpi().saveCheckpoint(KEY_PREFIX, GridTestIoUtils.serializeJdk(state2), 0, true); assertWithRetries(new GridAbsClosureX() { - @Override public void applyx() throws IgniteCheckedException { + @Override public void applyx() { assertNotNull(getSpi().loadCheckpoint(KEY_PREFIX)); } }); @@ -197,7 +197,7 @@ public class S3CheckpointSpiSelfTest extends GridSpiAbstractTest<S3CheckpointSpi getSpi().removeCheckpoint(KEY_PREFIX); assertWithRetries(new GridAbsClosureX() { - @Override public void applyx() throws IgniteCheckedException { + @Override public void applyx() { assertNull(getSpi().loadCheckpoint(KEY_PREFIX)); } }); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/clients/src/test/java/org/apache/ignite/internal/client/ClientStartNodeTask.java ---------------------------------------------------------------------- diff --git a/modules/clients/src/test/java/org/apache/ignite/internal/client/ClientStartNodeTask.java b/modules/clients/src/test/java/org/apache/ignite/internal/client/ClientStartNodeTask.java index 006c168..1822790 100644 --- a/modules/clients/src/test/java/org/apache/ignite/internal/client/ClientStartNodeTask.java +++ b/modules/clients/src/test/java/org/apache/ignite/internal/client/ClientStartNodeTask.java @@ -131,7 +131,7 @@ public class ClientStartNodeTask extends TaskSingleJobSplitAdapter<String, Integ assert G.allGrids().isEmpty(); } - catch (IgniteCheckedException e) { + catch (Exception e) { System.err.println("Uncaught exception: " + e.getMessage()); e.printStackTrace(System.err); @@ -145,9 +145,8 @@ public class ClientStartNodeTask extends TaskSingleJobSplitAdapter<String, Integ * @param add New nodes count. * @param rmv Remove nodes count. * @param type Type of nodes to manipulate. - * @throws IgniteCheckedException On any exception. */ - private static void changeTopology(Ignite parent, int add, int rmv, String type) throws IgniteCheckedException { + private static void changeTopology(Ignite parent, int add, int rmv, String type) { Collection<ComputeTaskFuture<?>> tasks = new ArrayList<>(); IgniteCompute comp = parent.compute().withAsync(); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/clients/src/test/java/org/apache/ignite/internal/processors/rest/RestProcessorTest.java ---------------------------------------------------------------------- diff --git a/modules/clients/src/test/java/org/apache/ignite/internal/processors/rest/RestProcessorTest.java b/modules/clients/src/test/java/org/apache/ignite/internal/processors/rest/RestProcessorTest.java index 0a45d45..1c61c75 100644 --- a/modules/clients/src/test/java/org/apache/ignite/internal/processors/rest/RestProcessorTest.java +++ b/modules/clients/src/test/java/org/apache/ignite/internal/processors/rest/RestProcessorTest.java @@ -132,9 +132,9 @@ public class RestProcessorTest extends GridCommonAbstractTest { } /** - * @throws IgniteCheckedException If failed. + * */ - private void populateCache() throws IgniteCheckedException { + private void populateCache() { IgniteCache<String, Object> cache = G.ignite().jcache(null); cache.put("int", intValue()); @@ -152,9 +152,9 @@ public class RestProcessorTest extends GridCommonAbstractTest { } /** - * @throws IgniteCheckedException If failed. + * */ - private void deployTasks() throws IgniteCheckedException { + private void deployTasks() { G.ignite().compute().localDeployTask(TestTask1.class, TestTask1.class.getClassLoader()); G.ignite().compute().localDeployTask(TestTask2.class, TestTask2.class.getClassLoader()); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheSwapManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheSwapManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheSwapManager.java index 0a7b768..c1c8b0d 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheSwapManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheSwapManager.java @@ -1560,9 +1560,7 @@ public class GridCacheSwapManager<K, V> extends GridCacheManagerAdapter<K, V> { cctx.affinity().backupPartitions(cctx.localNodeId(), topVer); return new PartitionsIterator(parts) { - @Override protected GridCloseableIterator<? extends Map.Entry<byte[], byte[]>> partitionIterator(int part) - throws IgniteCheckedException - { + @Override protected GridCloseableIterator<? extends Map.Entry<byte[], byte[]>> partitionIterator(int part) { return offheap.iterator(spaceName, part); } }; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheDistributedQueryManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheDistributedQueryManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheDistributedQueryManager.java index c08f047..c9ef668 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheDistributedQueryManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheDistributedQueryManager.java @@ -193,10 +193,8 @@ public class GridCacheDistributedQueryManager<K, V> extends GridCacheQueryManage * @param sndId Sender node id. * @param req Query request. * @return Query info. - * @throws ClassNotFoundException If class not found. */ - @Nullable private GridCacheQueryInfo distributedQueryInfo(UUID sndId, GridCacheQueryRequest<K, V> req) - throws ClassNotFoundException { + @Nullable private GridCacheQueryInfo distributedQueryInfo(UUID sndId, GridCacheQueryRequest<K, V> req) { IgnitePredicate<Cache.Entry<Object, Object>> prjPred = req.projectionFilter() == null ? F.<Cache.Entry<Object, Object>>alwaysTrue() : req.projectionFilter(); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryManager.java index 362077f..8fa48aa 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryManager.java @@ -833,7 +833,7 @@ public abstract class GridCacheQueryManager<K, V> extends GridCacheManagerAdapte sendTtlUpdate(); } - @Override protected void onClose() throws IgniteCheckedException { + @Override protected void onClose() { sendTtlUpdate(); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/main/java/org/apache/ignite/internal/processors/dataload/GridDataLoaderProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/dataload/GridDataLoaderProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/dataload/GridDataLoaderProcessor.java index acac20d..d470d02 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/dataload/GridDataLoaderProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/dataload/GridDataLoaderProcessor.java @@ -78,7 +78,7 @@ public class GridDataLoaderProcessor<K, V> extends GridProcessorAdapter { return; flusher = new IgniteThread(new GridWorker(ctx.gridName(), "grid-data-loader-flusher", log) { - @Override protected void body() throws InterruptedException, IgniteInterruptedCheckedException { + @Override protected void body() throws InterruptedException { while (!isCancelled()) { IgniteDataLoaderImpl<K, V> ldr = flushQ.take(); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/DataStructuresProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/DataStructuresProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/DataStructuresProcessor.java index a2d69fb..6ae7188 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/DataStructuresProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/DataStructuresProcessor.java @@ -105,7 +105,7 @@ public final class DataStructuresProcessor extends GridProcessorAdapter { /** {@inheritDoc} */ @SuppressWarnings("unchecked") - @Override public void start() throws IgniteCheckedException { + @Override public void start() { if (ctx.config().isDaemon()) return; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDataManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDataManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDataManager.java index d2f4f23..e960422 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDataManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDataManager.java @@ -859,10 +859,8 @@ public class IgfsDataManager extends IgfsManager { * @param len Length. * @param maxLen Maximum allowed split length. * @param res Result collection to add regions to. - * @throws IgniteCheckedException If failed. */ - private void affinity0(IgfsFileInfo info, long start, long len, long maxLen, Deque<IgfsBlockLocation> res) - throws IgniteCheckedException { + private void affinity0(IgfsFileInfo info, long start, long len, long maxLen, Deque<IgfsBlockLocation> res) { long firstGrpIdx = start / grpBlockSize; long limitGrpIdx = (start + len + grpBlockSize - 1) / grpBlockSize; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsImpl.java index cb27cc9..eff987e 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsImpl.java @@ -397,7 +397,7 @@ public final class IgfsImpl implements IgfsEx { /** {@inheritDoc} */ @SuppressWarnings("ConstantConditions") - @Override public IgfsStatus globalSpace() throws IgniteCheckedException { + @Override public IgfsStatus globalSpace() { if (enterBusy()) { try { IgniteBiTuple<Long, Long> space = igfsCtx.kernalContext().grid().compute().execute( @@ -1992,11 +1992,9 @@ public final class IgfsImpl implements IgfsEx { * @param bufSize The size of the buffer to be used. * @param mode IGFS mode. * @param batch Optional secondary file system batch. - * @throws IgniteCheckedException In case of error. */ IgfsEventAwareOutputStream(IgfsPath path, IgfsFileInfo fileInfo, - IgniteUuid parentId, int bufSize, IgfsMode mode, @Nullable IgfsFileWorkerBatch batch) - throws IgniteCheckedException { + IgniteUuid parentId, int bufSize, IgfsMode mode, @Nullable IgfsFileWorkerBatch batch) { super(igfsCtx, path, fileInfo, parentId, bufSize, mode, batch, metrics); metrics.incrementFilesOpenedForWrite(); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsOutputStreamImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsOutputStreamImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsOutputStreamImpl.java index 7a6d946..5941579 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsOutputStreamImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsOutputStreamImpl.java @@ -96,11 +96,9 @@ class IgfsOutputStreamImpl extends IgfsOutputStreamAdapter { * @param mode Grid IGFS mode. * @param batch Optional secondary file system batch. * @param metrics Local IGFS metrics. - * @throws IgniteCheckedException If stream creation failed. */ IgfsOutputStreamImpl(IgfsContext igfsCtx, IgfsPath path, IgfsFileInfo fileInfo, IgniteUuid parentId, - int bufSize, IgfsMode mode, @Nullable IgfsFileWorkerBatch batch, IgfsLocalMetrics metrics) - throws IgniteCheckedException { + int bufSize, IgfsMode mode, @Nullable IgfsFileWorkerBatch batch, IgfsLocalMetrics metrics) { super(path, optimizeBufferSize(bufSize, fileInfo)); assert fileInfo != null; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/main/java/org/apache/ignite/internal/processors/job/GridJobWorker.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/job/GridJobWorker.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/job/GridJobWorker.java index e35bd47..fdfc5c8 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/job/GridJobWorker.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/job/GridJobWorker.java @@ -470,7 +470,7 @@ public class GridJobWorker extends GridWorker implements GridTimeoutObject { sndRes = false; else { res = U.wrapThreadLoader(dep.classLoader(), new Callable<Object>() { - @Nullable @Override public Object call() throws IgniteCheckedException { + @Nullable @Override public Object call() { try { if (internal && ctx.config().isPeerClassLoadingEnabled()) ctx.job().internal(true); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskWorker.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskWorker.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskWorker.java index 258537e..965a75e 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskWorker.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskWorker.java @@ -411,7 +411,7 @@ class GridTaskWorker<T, R> extends GridWorker implements GridTimeoutObject { Map<? extends ComputeJob, ClusterNode> mappedJobs = U.wrapThreadLoader(dep.classLoader(), new Callable<Map<? extends ComputeJob, ClusterNode>>() { - @Override public Map<? extends ComputeJob, ClusterNode> call() throws IgniteCheckedException { + @Override public Map<? extends ComputeJob, ClusterNode> call() { return task.map(shuffledNodes, arg); } }); @@ -902,7 +902,7 @@ class GridTaskWorker<T, R> extends GridWorker implements GridTimeoutObject { try { // Reduce results. reduceRes = U.wrapThreadLoader(dep.classLoader(), new Callable<R>() { - @Nullable @Override public R call() throws IgniteCheckedException { + @Nullable @Override public R call() { return task.reduce(results); } }); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteUtils.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteUtils.java b/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteUtils.java index 1348bb5..e4b23f1 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteUtils.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteUtils.java @@ -8406,13 +8406,13 @@ public abstract class IgniteUtils { * @param addrs Addresses. * @param port Port. * @return Resolved socket addresses. - * @throws IgniteCheckedException If failed. + * @throws IgniteSpiException If failed. */ public static Collection<InetSocketAddress> resolveAddresses( AddressResolver addrRslvr, Iterable<String> addrs, int port - ) throws IgniteCheckedException { + ) throws IgniteSpiException { assert addrRslvr != null; Collection<InetSocketAddress> extAddrs = new HashSet<>(); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/main/java/org/apache/ignite/internal/util/typedef/X.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/typedef/X.java b/modules/core/src/main/java/org/apache/ignite/internal/util/typedef/X.java index 63b0470..fe48475 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/typedef/X.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/typedef/X.java @@ -764,9 +764,8 @@ public final class X { * Synchronously waits for all futures in the collection. * * @param futs Futures to wait for. - * @throws IgniteCheckedException If any of the futures threw exception. */ - public static void waitAll(@Nullable Iterable<IgniteFuture<?>> futs) throws IgniteCheckedException { + public static void waitAll(@Nullable Iterable<IgniteFuture<?>> futs) { if (F.isEmpty(futs)) return; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/main/java/org/apache/ignite/spi/IgniteSpiThreadFactory.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/IgniteSpiThreadFactory.java b/modules/core/src/main/java/org/apache/ignite/spi/IgniteSpiThreadFactory.java index cda4b7e..2344d3f 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/IgniteSpiThreadFactory.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/IgniteSpiThreadFactory.java @@ -53,7 +53,7 @@ public class IgniteSpiThreadFactory implements ThreadFactory { @Override public Thread newThread(final Runnable r) { return new IgniteSpiThread(gridName, threadName, log) { /** {@inheritDoc} */ - @Override protected void body() throws InterruptedException { + @Override protected void body() { r.run(); } }; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java index 59336ad..87aebc4 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java @@ -709,17 +709,12 @@ public class TcpDiscoverySpi extends TcpDiscoverySpiAdapter implements TcpDiscov metricsProvider, locNodeVer); - try { - Collection<InetSocketAddress> extAddrs = addrRslvr == null ? null : - U.resolveAddresses(addrRslvr, F.flat(Arrays.asList(addrs.get1(), addrs.get2())), - locNode.discoveryPort()); + Collection<InetSocketAddress> extAddrs = addrRslvr == null ? null : + U.resolveAddresses(addrRslvr, F.flat(Arrays.asList(addrs.get1(), addrs.get2())), + locNode.discoveryPort()); - if (extAddrs != null) - locNodeAttrs.put(createSpiAttributeName(ATTR_EXT_ADDRS), extAddrs); - } - catch (IgniteCheckedException e) { - throw new IgniteSpiException("Failed to resolve local host to addresses: " + locHost, e); - } + if (extAddrs != null) + locNodeAttrs.put(createSpiAttributeName(ATTR_EXT_ADDRS), extAddrs); locNode.setAttributes(locNodeAttrs); @@ -2874,7 +2869,7 @@ public class TcpDiscoverySpi extends TcpDiscoverySpiAdapter implements TcpDiscov U.error(log, "Failed to send message to next node [next=" + next.id() + ", msg=" + msg + ", err=" + e + ']', e); - onException("Failed to send message to next node [next=" + next.id() + ", msg=" + msg + ']', + onException("Failed to send message to next node [next=" + next.id() + ", msg=" + msg + ']', e); if (e instanceof SocketTimeoutException || X.hasCause(e, SocketTimeoutException.class)) { http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/main/java/org/apache/ignite/spi/swapspace/file/FileSwapSpaceSpi.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/swapspace/file/FileSwapSpaceSpi.java b/modules/core/src/main/java/org/apache/ignite/spi/swapspace/file/FileSwapSpaceSpi.java index ec2ef97..122d0ed 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/swapspace/file/FileSwapSpaceSpi.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/swapspace/file/FileSwapSpaceSpi.java @@ -529,7 +529,7 @@ public class FileSwapSpaceSpi extends IgniteSpiAdapter implements SwapSpaceSpi, private IgniteSpiCloseableIterator<Map.Entry<byte[], byte[]>> rawIterator( final Iterator<Map.Entry<SwapKey, byte[]>> iter) { return new GridCloseableIteratorAdapter<Map.Entry<byte[], byte[]>>() { - @Override protected Map.Entry<byte[], byte[]> onNext() throws IgniteCheckedException { + @Override protected Map.Entry<byte[], byte[]> onNext() { Map.Entry<SwapKey, byte[]> x = iter.next(); return new T2<>(keyBytes(x.getKey()), x.getValue()); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/GridEventStorageSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridEventStorageSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridEventStorageSelfTest.java index 60a5f53..8748c73 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/GridEventStorageSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/GridEventStorageSelfTest.java @@ -186,9 +186,8 @@ public class GridEventStorageSelfTest extends GridCommonAbstractTest { * Create events in grid. * * @param ignite Grid. - * @throws IgniteCheckedException In case of error. */ - private void generateEvents(Ignite ignite) throws IgniteCheckedException { + private void generateEvents(Ignite ignite) { ignite.compute().localDeployTask(GridEventTestTask.class, GridEventTestTask.class.getClassLoader()); ignite.compute().execute(GridEventTestTask.class.getName(), null); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/GridJobMasterLeaveAwareSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridJobMasterLeaveAwareSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridJobMasterLeaveAwareSelfTest.java index 57c45b7..fc5cf26 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/GridJobMasterLeaveAwareSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/GridJobMasterLeaveAwareSelfTest.java @@ -253,7 +253,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest { */ public void testApply1() throws Exception { testMasterLeaveAwareCallback(1, new CX1<ClusterGroup, IgniteFuture<?>>() { - @Override public IgniteFuture<?> applyx(ClusterGroup grid) throws IgniteCheckedException { + @Override public IgniteFuture<?> applyx(ClusterGroup grid) { IgniteCompute comp = compute(grid).withAsync(); comp.apply(new TestClosure(), "arg"); @@ -268,7 +268,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest { */ public void testApply2() throws Exception { testMasterLeaveAwareCallback(2, new CX1<ClusterGroup, IgniteFuture<?>>() { - @Override public IgniteFuture<?> applyx(ClusterGroup grid) throws IgniteCheckedException { + @Override public IgniteFuture<?> applyx(ClusterGroup grid) { IgniteCompute comp = compute(grid).withAsync(); comp.apply(new TestClosure(), Arrays.asList("arg1", "arg2")); @@ -283,7 +283,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest { */ public void testApply3() throws Exception { testMasterLeaveAwareCallback(2, new CX1<ClusterGroup, IgniteFuture<?>>() { - @Override public IgniteFuture<?> applyx(ClusterGroup grid) throws IgniteCheckedException { + @Override public IgniteFuture<?> applyx(ClusterGroup grid) { IgniteCompute comp = compute(grid).withAsync(); comp.apply(new TestClosure(), @@ -308,7 +308,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest { */ public void testRun1() throws Exception { testMasterLeaveAwareCallback(1, new CX1<ClusterGroup, IgniteFuture<?>>() { - @Override public IgniteFuture<?> applyx(ClusterGroup prj) throws IgniteCheckedException { + @Override public IgniteFuture<?> applyx(ClusterGroup prj) { IgniteCompute comp = compute(prj).withAsync(); comp.run(new TestRunnable()); @@ -323,7 +323,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest { */ public void testRun2() throws Exception { testMasterLeaveAwareCallback(2, new CX1<ClusterGroup, IgniteFuture<?>>() { - @Override public IgniteFuture<?> applyx(ClusterGroup prj) throws IgniteCheckedException { + @Override public IgniteFuture<?> applyx(ClusterGroup prj) { IgniteCompute comp = compute(prj).withAsync(); comp.run(Arrays.asList(new TestRunnable(), new TestRunnable())); @@ -338,7 +338,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest { */ public void testCall1() throws Exception { testMasterLeaveAwareCallback(1, new CX1<ClusterGroup, IgniteFuture<?>>() { - @Override public IgniteFuture<?> applyx(ClusterGroup prj) throws IgniteCheckedException { + @Override public IgniteFuture<?> applyx(ClusterGroup prj) { IgniteCompute comp = compute(prj).withAsync(); comp.call(new TestCallable()); @@ -353,7 +353,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest { */ public void testCall2() throws Exception { testMasterLeaveAwareCallback(2, new CX1<ClusterGroup, IgniteFuture<?>>() { - @Override public IgniteFuture<?> applyx(ClusterGroup prj) throws IgniteCheckedException { + @Override public IgniteFuture<?> applyx(ClusterGroup prj) { IgniteCompute comp = compute(prj).withAsync(); comp.call(Arrays.asList(new TestCallable(), new TestCallable())); @@ -368,7 +368,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest { */ public void testCall3() throws Exception { testMasterLeaveAwareCallback(2, new CX1<ClusterGroup, IgniteFuture<?>>() { - @Override public IgniteFuture<?> applyx(ClusterGroup prj) throws IgniteCheckedException { + @Override public IgniteFuture<?> applyx(ClusterGroup prj) { IgniteCompute comp = compute(prj).withAsync(); comp.call( @@ -393,7 +393,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest { */ public void testBroadcast1() throws Exception { testMasterLeaveAwareCallback(1, new CX1<ClusterGroup, IgniteFuture<?>>() { - @Override public IgniteFuture<?> applyx(ClusterGroup prj) throws IgniteCheckedException { + @Override public IgniteFuture<?> applyx(ClusterGroup prj) { IgniteCompute comp = compute(prj).withAsync(); comp.broadcast(new TestRunnable()); @@ -408,7 +408,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest { */ public void testBroadcast2() throws Exception { testMasterLeaveAwareCallback(1, new CX1<ClusterGroup, IgniteFuture<?>>() { - @Override public IgniteFuture<?> applyx(ClusterGroup prj) throws IgniteCheckedException { + @Override public IgniteFuture<?> applyx(ClusterGroup prj) { IgniteCompute comp = compute(prj).withAsync(); comp.broadcast(new TestCallable()); @@ -423,7 +423,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest { */ public void testBroadcast3() throws Exception { testMasterLeaveAwareCallback(1, new CX1<ClusterGroup, IgniteFuture<?>>() { - @Override public IgniteFuture<?> applyx(ClusterGroup prj) throws IgniteCheckedException { + @Override public IgniteFuture<?> applyx(ClusterGroup prj) { IgniteCompute comp = compute(prj).withAsync(); comp.broadcast(new TestClosure(), "arg"); @@ -438,7 +438,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest { */ public void testAffinityRun() throws Exception { testMasterLeaveAwareCallback(1, new CX1<ClusterGroup, IgniteFuture<?>>() { - @Override public IgniteFuture<?> applyx(ClusterGroup prj) throws IgniteCheckedException { + @Override public IgniteFuture<?> applyx(ClusterGroup prj) { IgniteCompute comp = compute(prj).withAsync(); CacheAffinity<Object> aff = prj.ignite().affinity(null); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/GridMultipleJobsSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridMultipleJobsSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridMultipleJobsSelfTest.java index 24a117c..565aaa7 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/GridMultipleJobsSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/GridMultipleJobsSelfTest.java @@ -158,7 +158,7 @@ public class GridMultipleJobsSelfTest extends GridCommonAbstractTest { X.println("Submitted jobs: " + cnt); fut.listenAsync(new CIX1<IgniteFuture<Boolean>>() { - @Override public void applyx(IgniteFuture<Boolean> f) throws IgniteCheckedException { + @Override public void applyx(IgniteFuture<Boolean> f) { try { assert f.get(); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/GridTaskContinuousMapperSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridTaskContinuousMapperSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridTaskContinuousMapperSelfTest.java index e254957..3ae94b3 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/GridTaskContinuousMapperSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/GridTaskContinuousMapperSelfTest.java @@ -133,11 +133,10 @@ public class GridTaskContinuousMapperSelfTest extends GridCommonAbstractTest { /** * @param mapper Continuous mapper. - * @throws IgniteCheckedException Thrown if any exception occurs. */ @SuppressWarnings("unused") @TaskContinuousMapperResource - private void setMapper(ComputeTaskContinuousMapper mapper) throws IgniteCheckedException { + private void setMapper(ComputeTaskContinuousMapper mapper) { this.mapper = mapper; mapper.send(new TestJob()); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/GridTaskExecutionContextSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridTaskExecutionContextSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridTaskExecutionContextSelfTest.java index 82db502..d16aa1f 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/GridTaskExecutionContextSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/GridTaskExecutionContextSelfTest.java @@ -92,7 +92,7 @@ public class GridTaskExecutionContextSelfTest extends GridCommonAbstractTest { */ public void testWithNoFailoverClosure() throws Exception { final IgniteRunnable r = new GridAbsClosureX() { - @Override public void applyx() throws IgniteCheckedException { + @Override public void applyx() { CNT.incrementAndGet(); throw new ComputeExecutionRejectedException("Expected error."); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/managers/checkpoint/GridCheckpointManagerAbstractSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/managers/checkpoint/GridCheckpointManagerAbstractSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/managers/checkpoint/GridCheckpointManagerAbstractSelfTest.java index e31ae8e..e6c8889 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/managers/checkpoint/GridCheckpointManagerAbstractSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/managers/checkpoint/GridCheckpointManagerAbstractSelfTest.java @@ -318,7 +318,7 @@ public abstract class GridCheckpointManagerAbstractSelfTest extends GridCommonAb taskSes.saveCheckpoint(key2, val2, SESSION_SCOPE, 0); assertWithRetries(new GridAbsClosureX() { - @Override public void applyx() throws IgniteCheckedException { + @Override public void applyx() { assert val1.equals(taskSes.loadCheckpoint(key1)); assert val2.equals(taskSes.loadCheckpoint(key2)); } @@ -329,7 +329,7 @@ public abstract class GridCheckpointManagerAbstractSelfTest extends GridCommonAb taskSes.saveCheckpoint(key2, val1, SESSION_SCOPE, 0, false); assertWithRetries(new GridAbsClosureX() { - @Override public void applyx() throws IgniteCheckedException { + @Override public void applyx() { assert val1.equals(taskSes.loadCheckpoint(key1)); assert val2.equals(taskSes.loadCheckpoint(key2)); } @@ -339,7 +339,7 @@ public abstract class GridCheckpointManagerAbstractSelfTest extends GridCommonAb taskSes.saveCheckpoint(key2, val1, SESSION_SCOPE, 0, true); assertWithRetries(new GridAbsClosureX() { - @Override public void applyx() throws IgniteCheckedException { + @Override public void applyx() { assert val2.equals(taskSes.loadCheckpoint(key1)); assert val1.equals(taskSes.loadCheckpoint(key2)); } @@ -351,7 +351,7 @@ public abstract class GridCheckpointManagerAbstractSelfTest extends GridCommonAb assert !taskSes.removeCheckpoint(key2); assertWithRetries(new GridAbsClosureX() { - @Override public void applyx() throws IgniteCheckedException { + @Override public void applyx() { assert taskSes.loadCheckpoint(key1) == null; assert taskSes.loadCheckpoint(key2) == null; } @@ -375,7 +375,7 @@ public abstract class GridCheckpointManagerAbstractSelfTest extends GridCommonAb } assertWithRetries(new GridAbsClosureX() { - @Override public void applyx() throws IgniteCheckedException { + @Override public void applyx() { assert taskSes.loadCheckpoint(key1) == null; assert taskSes.loadCheckpoint(key2) == null; } @@ -502,7 +502,7 @@ public abstract class GridCheckpointManagerAbstractSelfTest extends GridCommonAb rmvLatch.countDown(); assertWithRetries(new GridAbsClosureX() { - @Override public void applyx() throws IgniteCheckedException { + @Override public void applyx() { assert taskSes.loadCheckpoint(GLOBAL_KEY) == null; assert taskSes.loadCheckpoint(SES_KEY) == null; } @@ -556,7 +556,7 @@ public abstract class GridCheckpointManagerAbstractSelfTest extends GridCommonAb // Test that checkpoints were saved properly. assertWithRetries(new GridAbsClosureX() { - @Override public void applyx() throws IgniteCheckedException { + @Override public void applyx() { assert GLOBAL_VAL.equals(taskSes.loadCheckpoint(GLOBAL_KEY)); assert SES_VAL.equals(taskSes.loadCheckpoint(SES_KEY)); } @@ -573,7 +573,7 @@ public abstract class GridCheckpointManagerAbstractSelfTest extends GridCommonAb // Test that checkpoints were not overwritten. assertWithRetries(new GridAbsClosureX() { - @Override public void applyx() throws IgniteCheckedException { + @Override public void applyx() { assert GLOBAL_VAL.equals(taskSes.loadCheckpoint(GLOBAL_KEY)); assert SES_VAL.equals(taskSes.loadCheckpoint(SES_KEY)); } @@ -589,7 +589,7 @@ public abstract class GridCheckpointManagerAbstractSelfTest extends GridCommonAb } assertWithRetries(new GridAbsClosureX() { - @Override public void applyx() throws IgniteCheckedException { + @Override public void applyx() { assertEquals(SES_VAL_OVERWRITTEN, taskSes.loadCheckpoint(GLOBAL_KEY)); assertEquals(GLOBAL_VAL_OVERWRITTEN, taskSes.loadCheckpoint(SES_KEY)); } @@ -608,7 +608,7 @@ public abstract class GridCheckpointManagerAbstractSelfTest extends GridCommonAb assert !taskSes.removeCheckpoint(SES_KEY); assertWithRetries(new GridAbsClosureX() { - @Override public void applyx() throws IgniteCheckedException { + @Override public void applyx() { assert taskSes.loadCheckpoint(GLOBAL_KEY) == null; assert taskSes.loadCheckpoint(SES_KEY) == null; } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java index 3ab4544..43dc0ce 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java @@ -3659,7 +3659,7 @@ public abstract class GridCacheAbstractFullApiSelfTest extends GridCacheAbstract }); CU.inTx(ignite(0), jcache(), concurrency, isolation, new CIX1<IgniteCache<String, Integer>>() { - @Override public void applyx(IgniteCache<String, Integer> cache) throws IgniteCheckedException { + @Override public void applyx(IgniteCache<String, Integer> cache) { for (int i = 0; i < cnt; i++) assertTrue(cache.remove("key" + i)); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheConcurrentTxMultiNodeTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheConcurrentTxMultiNodeTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheConcurrentTxMultiNodeTest.java index 6c21b28..d841063 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheConcurrentTxMultiNodeTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheConcurrentTxMultiNodeTest.java @@ -658,16 +658,15 @@ public class GridCacheConcurrentTxMultiNodeTest extends GridCommonAbstractTest { stopTimer("commit"); } } - catch (IgniteCheckedException e) { + catch (Exception e) { e.printStackTrace(); } } /** * @return New ID. - * @throws IgniteCheckedException If failed. */ - private long getId() throws IgniteCheckedException { + private long getId() { IgniteAtomicSequence seq = ignite.atomicSequence("ID", 0, true); return seq.incrementAndGet(); @@ -705,9 +704,8 @@ public class GridCacheConcurrentTxMultiNodeTest extends GridCommonAbstractTest { * @param o Object to put. * @param cacheKey Cache key. * @param terminalId Terminal ID. - * @throws IgniteCheckedException If failed. */ - private void put(Object o, String cacheKey, String terminalId) throws IgniteCheckedException { + private void put(Object o, String cacheKey, String terminalId) { // GridCache<CacheAffinityKey<String>, Object> cache = ((IgniteKernal)ignite).cache(null); // // CacheAffinityKey<String> affinityKey = new CacheAffinityKey<>(cacheKey, terminalId); @@ -722,10 +720,9 @@ public class GridCacheConcurrentTxMultiNodeTest extends GridCommonAbstractTest { * @param cacheKey Cache key. * @param terminalId Terminal ID. * @return Cached object. - * @throws IgniteCheckedException If failed. */ @SuppressWarnings({"RedundantCast"}) - private <T> Object get(String cacheKey, String terminalId) throws IgniteCheckedException { + private <T> Object get(String cacheKey, String terminalId) { Object key = new CacheAffinityKey<>(cacheKey, terminalId); return (T) ignite.jcache(null).get(key); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCachePutAllFailoverSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCachePutAllFailoverSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCachePutAllFailoverSelfTest.java index 1fef3c6..9d2fe99 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCachePutAllFailoverSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCachePutAllFailoverSelfTest.java @@ -558,11 +558,8 @@ public class GridCachePutAllFailoverSelfTest extends GridCommonAbstractTest { * @param workerNode Worker node. * @param keys Keys that are suspected to be absent * @return List of absent keys. If no keys are absent, the list is empty. - * @throws IgniteCheckedException If error occurs. */ - private Collection<Integer> findAbsentKeys(Ignite workerNode, - Collection<Integer> keys) throws IgniteCheckedException { - + private Collection<Integer> findAbsentKeys(Ignite workerNode, Collection<Integer> keys) { Collection<Integer> ret = new ArrayList<>(keys.size()); IgniteCache<Object, Object> cache = workerNode.jcache(CACHE_NAME); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteTxMultiNodeAbstractTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteTxMultiNodeAbstractTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteTxMultiNodeAbstractTest.java index e3adab1..d2aaf93 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteTxMultiNodeAbstractTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteTxMultiNodeAbstractTest.java @@ -153,10 +153,9 @@ public abstract class IgniteTxMultiNodeAbstractTest extends GridCommonAbstractTe * @param ignite Grid. * @param itemKey Item key. * @param retry Retry count. - * @throws IgniteCheckedException If failed. */ @SuppressWarnings("unchecked") - private void onItemNear(boolean putCntr, Ignite ignite, String itemKey, int retry) throws IgniteCheckedException { + private void onItemNear(boolean putCntr, Ignite ignite, String itemKey, int retry) { IgniteCache<String, Integer> cache = ignite.jcache(null); UUID locId = ignite.cluster().localNode().id(); @@ -205,10 +204,9 @@ public abstract class IgniteTxMultiNodeAbstractTest extends GridCommonAbstractTe * @param ignite Grid. * @param itemKey Item key. * @param retry Retry count. - * @throws IgniteCheckedException If failed. */ @SuppressWarnings("unchecked") - private void onItemPrimary(boolean putCntr, Ignite ignite, String itemKey, int retry) throws IgniteCheckedException { + private void onItemPrimary(boolean putCntr, Ignite ignite, String itemKey, int retry) { IgniteCache<String, Integer> cache = ignite.jcache(null); UUID locId = ignite.cluster().localNode().id(); @@ -349,10 +347,9 @@ public abstract class IgniteTxMultiNodeAbstractTest extends GridCommonAbstractTe * @param putCntr Put counter to cache. * @param ignite Grid. * @param retry Retry count. - * @throws IgniteCheckedException If failed. */ @SuppressWarnings("unchecked") - private void onRemoveItemSimple(boolean putCntr, Ignite ignite, int retry) throws IgniteCheckedException { + private void onRemoveItemSimple(boolean putCntr, Ignite ignite, int retry) { IgniteCache<String, Integer> cache = ignite.jcache(null); UUID locId = ignite.cluster().localNode().id(); @@ -417,9 +414,8 @@ public abstract class IgniteTxMultiNodeAbstractTest extends GridCommonAbstractTe * * @param putCntr Put counter to cache. * @param ignite Grid. - * @throws IgniteCheckedException If failed. */ - private void retries(Ignite ignite, boolean putCntr) throws IgniteCheckedException { + private void retries(Ignite ignite, boolean putCntr) { UUID nodeId = ignite.cluster().localNode().id(); for (int i = 0; i < RETRIES; i++) { @@ -469,9 +465,8 @@ public abstract class IgniteTxMultiNodeAbstractTest extends GridCommonAbstractTe * * @param putCntr Put counter to cache. * @param ignite Grid. - * @throws IgniteCheckedException If failed. */ - private void removeRetriesSimple(Ignite ignite, boolean putCntr) throws IgniteCheckedException { + private void removeRetriesSimple(Ignite ignite, boolean putCntr) { for (int i = 0; i < RETRIES; i++) { if (DEBUG) ignite.log().info("***"); @@ -551,12 +546,7 @@ public abstract class IgniteTxMultiNodeAbstractTest extends GridCommonAbstractTe threads.add(new Thread("thread-#" + i) { @Override public void run() { - try { - retries(grid(gridId), false); - } - catch (IgniteCheckedException e) { - throw new IgniteException(e); - } + retries(grid(gridId), false); } }); } @@ -594,12 +584,7 @@ public abstract class IgniteTxMultiNodeAbstractTest extends GridCommonAbstractTe threads.add(new Thread() { @Override public void run() { - try { - retries(grid(gridId), true); - } - catch (IgniteCheckedException e) { - throw new IgniteException(e); - } + retries(grid(gridId), true); } }); } @@ -808,9 +793,9 @@ public abstract class IgniteTxMultiNodeAbstractTest extends GridCommonAbstractTe } /** - * @throws IgniteCheckedException If failed. + * */ - private void printCounter() throws IgniteCheckedException { + private void printCounter() { info("***"); info("*** Peeked counter: " + grid(0).jcache(null).localPeek(CNTR_KEY, CachePeekMode.ONHEAP)); info("*** Got counter: " + grid(0).jcache(null).get(CNTR_KEY)); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheAtomicReferenceMultiNodeAbstractTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheAtomicReferenceMultiNodeAbstractTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheAtomicReferenceMultiNodeAbstractTest.java index dbdd194..412ad62 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheAtomicReferenceMultiNodeAbstractTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheAtomicReferenceMultiNodeAbstractTest.java @@ -65,7 +65,7 @@ public abstract class GridCacheAtomicReferenceMultiNodeAbstractTest extends Igni // Execute task on all grid nodes. ignite.compute().call(new IgniteCallable<Object>() { - @Override public String call() throws IgniteCheckedException { + @Override public String call() { IgniteAtomicReference<String> ref = ignite.atomicReference(refName, val, true); assertEquals(val, ref.get()); @@ -78,7 +78,7 @@ public abstract class GridCacheAtomicReferenceMultiNodeAbstractTest extends Igni // Execute task on all grid nodes. ignite.compute().call(new IgniteCallable<String>() { - @Override public String call() throws IgniteCheckedException { + @Override public String call() { IgniteAtomicReference<String> ref = ignite.atomicReference(refName, val, true); assertEquals(val, ref.get()); @@ -91,7 +91,7 @@ public abstract class GridCacheAtomicReferenceMultiNodeAbstractTest extends Igni // Execute task on all grid nodes. ignite.compute().call(new IgniteCallable<String>() { - @Override public String call() throws IgniteCheckedException { + @Override public String call() { IgniteAtomicReference<String> ref = ignite.atomicReference(refName, val, true); assertEquals(newVal, ref.get()); @@ -125,7 +125,7 @@ public abstract class GridCacheAtomicReferenceMultiNodeAbstractTest extends Igni // Execute task on all grid nodes. ignite.compute().call(new IgniteCallable<String>() { - @Override public String call() throws IgniteCheckedException { + @Override public String call() { IgniteAtomicStamped<String, String> stamped = ignite.atomicStamped(stampedName, val, stamp, true); assertEquals(val, stamped.value()); @@ -139,7 +139,7 @@ public abstract class GridCacheAtomicReferenceMultiNodeAbstractTest extends Igni // Execute task on all grid nodes. ignite.compute().call(new IgniteCallable<String>() { - @Override public String call() throws IgniteCheckedException { + @Override public String call() { IgniteAtomicStamped<String, String> stamped = ignite.atomicStamped(stampedName, val, stamp, true); assertEquals(val, stamped.value()); @@ -153,7 +153,7 @@ public abstract class GridCacheAtomicReferenceMultiNodeAbstractTest extends Igni // Execute task on all grid nodes. ignite.compute().call(new IgniteCallable<String>() { - @Override public String call() throws IgniteCheckedException { + @Override public String call() { IgniteAtomicStamped<String, String> stamped = ignite.atomicStamped(stampedName, val, stamp, true); assertEquals(newVal, stamped.value()); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheMultiNodeDataStructureTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheMultiNodeDataStructureTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheMultiNodeDataStructureTest.java index dd7fa84..2599644 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheMultiNodeDataStructureTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheMultiNodeDataStructureTest.java @@ -53,9 +53,8 @@ public class GridCacheMultiNodeDataStructureTest { * * @param g Grid. * @param cacheName Cache name. - * @throws IgniteCheckedException If failed. */ - private static void sample(Ignite g, String cacheName) throws IgniteCheckedException { + private static void sample(Ignite g, String cacheName) { IgniteAtomicLong atomicLong = g.atomicLong("keygen", 0, true); IgniteAtomicSequence seq = g.atomicSequence("keygen", 0, true); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheSequenceMultiNodeAbstractSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheSequenceMultiNodeAbstractSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheSequenceMultiNodeAbstractSelfTest.java index fe67880..d6d7c40 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheSequenceMultiNodeAbstractSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheSequenceMultiNodeAbstractSelfTest.java @@ -126,7 +126,7 @@ public abstract class GridCacheSequenceMultiNodeAbstractSelfTest extends IgniteA final IgniteAtomicSequence seq = grid(0).atomicSequence(seqName, 0, true); grid(1).compute().run(new CAX() { - @Override public void applyx() throws IgniteCheckedException { + @Override public void applyx() { assertNotNull(seq); for (int i = 0; i < RETRIES; i++) http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/partitioned/GridCachePartitionedAtomicSequenceMultiThreadedTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/partitioned/GridCachePartitionedAtomicSequenceMultiThreadedTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/partitioned/GridCachePartitionedAtomicSequenceMultiThreadedTest.java index fabba18..806dafa 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/partitioned/GridCachePartitionedAtomicSequenceMultiThreadedTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/partitioned/GridCachePartitionedAtomicSequenceMultiThreadedTest.java @@ -151,7 +151,7 @@ public class GridCachePartitionedAtomicSequenceMultiThreadedTest extends IgniteA final IgniteAtomicSequence seq = grid(0).atomicSequence(seqName, 0L, true); runSequenceClosure(new GridInUnsafeClosure<IgniteAtomicSequence>() { - @Override public void apply(IgniteAtomicSequence t) throws IgniteCheckedException { + @Override public void apply(IgniteAtomicSequence t) { t.incrementAndGet(); } }, seq, ITERATION_NUM, THREAD_NUM); @@ -167,7 +167,7 @@ public class GridCachePartitionedAtomicSequenceMultiThreadedTest extends IgniteA final IgniteAtomicSequence seq = grid(0).atomicSequence(seqName, 0L, true); runSequenceClosure(new GridInUnsafeClosure<IgniteAtomicSequence>() { - @Override public void apply(IgniteAtomicSequence t) throws IgniteCheckedException { + @Override public void apply(IgniteAtomicSequence t) { t.incrementAndGet(); } }, seq, ITERATION_NUM, THREAD_NUM); @@ -183,7 +183,7 @@ public class GridCachePartitionedAtomicSequenceMultiThreadedTest extends IgniteA final IgniteAtomicSequence seq = grid(0).atomicSequence(seqName, 0L, true); runSequenceClosure(new GridInUnsafeClosure<IgniteAtomicSequence>() { - @Override public void apply(IgniteAtomicSequence t) throws IgniteCheckedException { + @Override public void apply(IgniteAtomicSequence t) { t.getAndIncrement(); } }, seq, ITERATION_NUM, THREAD_NUM); @@ -199,7 +199,7 @@ public class GridCachePartitionedAtomicSequenceMultiThreadedTest extends IgniteA final IgniteAtomicSequence seq = grid(0).atomicSequence(seqName, 0L, true); runSequenceClosure(new GridInUnsafeClosure<IgniteAtomicSequence>() { - @Override public void apply(IgniteAtomicSequence t) throws IgniteCheckedException { + @Override public void apply(IgniteAtomicSequence t) { t.getAndIncrement(); } }, seq, ITERATION_NUM, THREAD_NUM); @@ -215,7 +215,7 @@ public class GridCachePartitionedAtomicSequenceMultiThreadedTest extends IgniteA final IgniteAtomicSequence seq = grid(0).atomicSequence(seqName, 0L, true); runSequenceClosure(new GridInUnsafeClosure<IgniteAtomicSequence>() { - @Override public void apply(IgniteAtomicSequence t) throws IgniteCheckedException { + @Override public void apply(IgniteAtomicSequence t) { t.addAndGet(5); } }, seq, ITERATION_NUM, THREAD_NUM); @@ -231,7 +231,7 @@ public class GridCachePartitionedAtomicSequenceMultiThreadedTest extends IgniteA final IgniteAtomicSequence seq = grid(0).atomicSequence(seqName, 0L, true); runSequenceClosure(new GridInUnsafeClosure<IgniteAtomicSequence>() { - @Override public void apply(IgniteAtomicSequence t) throws IgniteCheckedException { + @Override public void apply(IgniteAtomicSequence t) { t.getAndAdd(5); } }, seq, ITERATION_NUM, THREAD_NUM); @@ -247,7 +247,7 @@ public class GridCachePartitionedAtomicSequenceMultiThreadedTest extends IgniteA final IgniteAtomicSequence seq = grid(0).atomicSequence(seqName, 0L, true); runSequenceClosure(new GridInUnsafeClosure<IgniteAtomicSequence>() { - @Override public void apply(IgniteAtomicSequence t) throws IgniteCheckedException { + @Override public void apply(IgniteAtomicSequence t) { t.incrementAndGet(); t.getAndIncrement(); t.incrementAndGet(); @@ -268,7 +268,7 @@ public class GridCachePartitionedAtomicSequenceMultiThreadedTest extends IgniteA final IgniteAtomicSequence seq = grid(0).atomicSequence(seqName, 0L, true); runSequenceClosure(new GridInUnsafeClosure<IgniteAtomicSequence>() { - @Override public void apply(IgniteAtomicSequence t) throws IgniteCheckedException { + @Override public void apply(IgniteAtomicSequence t) { t.getAndAdd(2); t.addAndGet(3); t.addAndGet(5); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/partitioned/GridCachePartitionedQueueEntryMoveSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/partitioned/GridCachePartitionedQueueEntryMoveSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/partitioned/GridCachePartitionedQueueEntryMoveSelfTest.java index e6039a8..4791191 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/partitioned/GridCachePartitionedQueueEntryMoveSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/partitioned/GridCachePartitionedQueueEntryMoveSelfTest.java @@ -104,7 +104,7 @@ public class GridCachePartitionedQueueEntryMoveSelfTest extends IgniteCollection //final CountDownLatch latch2 = new CountDownLatch(1); IgniteInternalFuture<?> fut1 = GridTestUtils.runAsync(new Callable<Void>() { - @Override public Void call() throws IgniteCheckedException { + @Override public Void call() { Ignite ignite = grid(0); IgniteQueue<Integer> queue = ignite.queue(queueName, http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheAbstractJobExecutionTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheAbstractJobExecutionTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheAbstractJobExecutionTest.java index d52b67e..fadf54b 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheAbstractJobExecutionTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheAbstractJobExecutionTest.java @@ -128,7 +128,7 @@ public abstract class GridCacheAbstractJobExecutionTest extends GridCommonAbstra @IgniteInstanceResource private Ignite ignite; - @Override public Void applyx(final Integer i) throws IgniteCheckedException { + @Override public Void applyx(final Integer i) { IgniteCache<String, int[]> cache = ignite.jcache(null); try (Transaction tx = ignite.transactions().txStart(concur, isolation)) { http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheEventAbstractTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheEventAbstractTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheEventAbstractTest.java index def2f09..24cd202 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheEventAbstractTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheEventAbstractTest.java @@ -135,10 +135,8 @@ public abstract class GridCacheEventAbstractTest extends GridCacheAbstractSelfTe /** * Clear caches without generating events. - * - * @throws IgniteCheckedException If failed to clear caches. */ - private void clearCaches() throws IgniteCheckedException { + private void clearCaches() { for (int i = 0; i < gridCnt; i++) { IgniteCache<String, Integer> cache = jcache(i); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridCacheDhtInternalEntrySelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridCacheDhtInternalEntrySelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridCacheDhtInternalEntrySelfTest.java index f88c080..cc274ce 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridCacheDhtInternalEntrySelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridCacheDhtInternalEntrySelfTest.java @@ -149,18 +149,16 @@ public class GridCacheDhtInternalEntrySelfTest extends GridCommonAbstractTest { /** * @param node Node. * @return Atomic long value. - * @throws IgniteCheckedException In case of error. */ - private Object peekNear(ClusterNode node) throws IgniteCheckedException { + private Object peekNear(ClusterNode node) { return grid(node).jcache(null).localPeek(new GridCacheInternalKeyImpl(ATOMIC_LONG_NAME), CachePeekMode.NEAR); } /** * @param node Node. * @return Atomic long value. - * @throws IgniteCheckedException In case of error. */ - private Object peekDht(ClusterNode node) throws IgniteCheckedException { + private Object peekDht(ClusterNode node) { return grid(node).jcache(null).localPeek(new GridCacheInternalKeyImpl(ATOMIC_LONG_NAME), CachePeekMode.BACKUP, CachePeekMode.PRIMARY); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridCacheDhtMultiBackupTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridCacheDhtMultiBackupTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridCacheDhtMultiBackupTest.java index ebbd71d..e40b670 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridCacheDhtMultiBackupTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridCacheDhtMultiBackupTest.java @@ -51,7 +51,7 @@ public class GridCacheDhtMultiBackupTest extends GridCommonAbstractTest { @IgniteInstanceResource private Ignite g; - @Override public void applyx() throws IgniteCheckedException { + @Override public void applyx() { X.println("Checking whether cache is empty."); IgniteCache<SampleKey, SampleValue> cache = g.jcache("partitioned"); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedHitsAndMissesSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedHitsAndMissesSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedHitsAndMissesSelfTest.java index d3464ea..8950f45 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedHitsAndMissesSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedHitsAndMissesSelfTest.java @@ -138,9 +138,8 @@ public class GridCachePartitionedHitsAndMissesSelfTest extends GridCommonAbstrac * Populates cache with data loader. * * @param g Grid. - * @throws IgniteCheckedException If failed. */ - private static void realTimePopulate(final Ignite g) throws IgniteCheckedException { + private static void realTimePopulate(final Ignite g) { try (IgniteDataLoader<Integer, Long> ldr = g.dataLoader(null)) { // Sets max values to 1 so cache metrics have correct values. ldr.perNodeParallelLoadOperations(1); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedMultiThreadedPutGetSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedMultiThreadedPutGetSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedMultiThreadedPutGetSelfTest.java index 32eff24..c4430dd 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedMultiThreadedPutGetSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedMultiThreadedPutGetSelfTest.java @@ -177,7 +177,7 @@ public class GridCachePartitionedMultiThreadedPutGetSelfTest extends GridCommonA multithreaded(new CAX() { @SuppressWarnings({"BusyWait"}) - @Override public void applyx() throws IgniteCheckedException { + @Override public void applyx() { IgniteCache<Integer, Integer> c = grid(0).jcache(null); for (int i = 0; i < TX_CNT; i++) { http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/eviction/random/GridCacheRandomEvictionPolicySelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/eviction/random/GridCacheRandomEvictionPolicySelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/eviction/random/GridCacheRandomEvictionPolicySelfTest.java index d77158a..d14e1a0 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/eviction/random/GridCacheRandomEvictionPolicySelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/eviction/random/GridCacheRandomEvictionPolicySelfTest.java @@ -176,7 +176,7 @@ public class GridCacheRandomEvictionPolicySelfTest extends t[i] = Integer.toString(i); multithreaded(new Callable() { - @Nullable @Override public Object call() throws IgniteCheckedException { + @Nullable @Override public Object call() { int runs = 3000; for (int i = 0; i < runs; i++) { http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/processors/closure/GridClosureProcessorSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/closure/GridClosureProcessorSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/closure/GridClosureProcessorSelfTest.java index fb5f8dc..0b178ff 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/closure/GridClosureProcessorSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/closure/GridClosureProcessorSelfTest.java @@ -187,10 +187,8 @@ public class GridClosureProcessorSelfTest extends GridCommonAbstractTest { * @param job Runnable job. * @param p Optional node predicate. * @return Future object. - * @throws IgniteCheckedException If failed. */ - private ComputeTaskFuture<?> runAsync(int idx, IgniteRunnable job, @Nullable IgnitePredicate<ClusterNode> p) - throws IgniteCheckedException { + private ComputeTaskFuture<?> runAsync(int idx, IgniteRunnable job, @Nullable IgnitePredicate<ClusterNode> p) { assert idx >= 0 && idx < NODES_CNT; assert job != null; @@ -210,10 +208,8 @@ public class GridClosureProcessorSelfTest extends GridCommonAbstractTest { * @param job Runnable job. * @param p Optional node predicate. * @return Future object. - * @throws IgniteCheckedException If failed. */ - private ComputeTaskFuture<?> broadcast(int idx, IgniteRunnable job, @Nullable IgnitePredicate<ClusterNode> p) - throws IgniteCheckedException { + private ComputeTaskFuture<?> broadcast(int idx, IgniteRunnable job, @Nullable IgnitePredicate<ClusterNode> p) { assert idx >= 0 && idx < NODES_CNT; assert job != null; @@ -283,10 +279,9 @@ public class GridClosureProcessorSelfTest extends GridCommonAbstractTest { * @param job Callable job. * @param p Optional node predicate. * @return Future object. - * @throws IgniteCheckedException If failed. */ private ComputeTaskFuture<Collection<Integer>> broadcast(int idx, IgniteCallable<Integer> job, - @Nullable IgnitePredicate<ClusterNode> p) throws IgniteCheckedException { + @Nullable IgnitePredicate<ClusterNode> p) { assert idx >= 0 && idx < NODES_CNT; assert job != null; @@ -306,10 +301,9 @@ public class GridClosureProcessorSelfTest extends GridCommonAbstractTest { * @param jobs Callable job. * @param p Optional node predicate. * @return Future object. - * @throws IgniteCheckedException If failed. */ private ComputeTaskFuture<Collection<Integer>> callAsync(int idx, Collection<TestCallable> jobs, - @Nullable IgnitePredicate<ClusterNode> p) throws IgniteCheckedException { + @Nullable IgnitePredicate<ClusterNode> p) { assert idx >= 0 && idx < NODES_CNT; assert !F.isEmpty(jobs);
