From fdcdb8f0ba9043f15dbd5132e94036679fc48332 Mon Sep 17 00:00:00 2001 From: AKuznetsov Date: Wed, 25 Feb 2015 16:50:45 +0700 Subject: [PATCH] # IGNITE-272 Code cleanup: Redundant Throws declaration. --- .../IgniteCountDownLatchExample.java | 3 +- .../MessagingPingPongListenActorExample.java | 3 +- .../spi/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 +- .../internal/processors/igfs/IgfsDataManager.java | 4 +-- .../ignite/internal/processors/igfs/IgfsImpl.java | 6 ++-- .../processors/igfs/IgfsOutputStreamImpl.java | 4 +-- .../internal/processors/job/GridJobWorker.java | 2 +- .../internal/processors/task/GridTaskWorker.java | 4 +-- .../apache/ignite/internal/util/IgniteUtils.java | 4 +-- .../org/apache/ignite/internal/util/typedef/X.java | 3 +- .../apache/ignite/spi/IgniteSpiThreadFactory.java | 2 +- .../ignite/spi/discovery/tcp/TcpDiscoverySpi.java | 15 +++------ .../spi/swapspace/file/FileSwapSpaceSpi.java | 2 +- .../ignite/internal/GridEventStorageSelfTest.java | 3 +- .../internal/GridJobMasterLeaveAwareSelfTest.java | 24 +++++++-------- .../ignite/internal/GridMultipleJobsSelfTest.java | 2 +- .../internal/GridTaskContinuousMapperSelfTest.java | 3 +- .../internal/GridTaskExecutionContextSelfTest.java | 2 +- .../GridCheckpointManagerAbstractSelfTest.java | 20 ++++++------ .../cache/GridCacheAbstractFullApiSelfTest.java | 2 +- .../cache/GridCacheConcurrentTxMultiNodeTest.java | 11 +++---- .../cache/GridCachePutAllFailoverSelfTest.java | 5 +-- .../cache/IgniteTxMultiNodeAbstractTest.java | 33 ++++++-------------- ...dCacheAtomicReferenceMultiNodeAbstractTest.java | 12 ++++---- .../GridCacheMultiNodeDataStructureTest.java | 3 +- ...GridCacheSequenceMultiNodeAbstractSelfTest.java | 2 +- ...PartitionedAtomicSequenceMultiThreadedTest.java | 16 +++++----- ...GridCachePartitionedQueueEntryMoveSelfTest.java | 2 +- .../GridCacheAbstractJobExecutionTest.java | 2 +- .../distributed/GridCacheEventAbstractTest.java | 4 +-- .../dht/GridCacheDhtInternalEntrySelfTest.java | 6 ++-- .../dht/GridCacheDhtMultiBackupTest.java | 2 +- .../GridCachePartitionedHitsAndMissesSelfTest.java | 3 +- ...achePartitionedMultiThreadedPutGetSelfTest.java | 2 +- .../GridCacheRandomEvictionPolicySelfTest.java | 2 +- .../closure/GridClosureProcessorSelfTest.java | 14 +++------ .../processors/igfs/IgfsAbstractSelfTest.java | 5 ++- .../processors/igfs/IgfsProcessorSelfTest.java | 3 +- .../streamer/GridStreamerEvictionSelfTest.java | 2 +- .../processors/streamer/GridStreamerSelfTest.java | 2 +- .../cache/GridCacheDataStructuresLoadTest.java | 36 ++++++++-------------- .../ignite/loadtests/cache/GridCacheLoadTest.java | 6 ++-- .../loadtests/cache/GridCacheSwapLoadTest.java | 5 ++- .../ignite/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 +- .../ignite/loadtests/mapper/GridNodeStartup.java | 3 +- .../loadtests/mergesort/GridMergeSortLoadTest.java | 3 +- .../streamer/GridStreamerIndexLoadTest.java | 4 +-- .../loadtests/swap/GridSwapEvictAllBenchmark.java | 3 +- .../GridSessionFutureWaitJobAttributeSelfTest.java | 3 +- .../GridSessionSetTaskAttributeSelfTest.java | 3 +- .../GridSessionTaskWaitJobAttributeSelfTest.java | 3 +- .../roundrobin/GridRoundRobinTestUtils.java | 6 ++-- .../streamer/index/GridStreamerIndexSelfTest.java | 17 +++++----- .../window/GridStreamerWindowSelfTest.java | 3 +- .../cache/GridAbstractCacheStoreSelfTest.java | 3 +- .../internal/igfs/hadoop/IgfsHadoopWrapper.java | 2 +- .../processors/hadoop/GridHadoopSetup.java | 3 +- .../planner/GridHadoopDefaultMapReducePlanner.java | 3 +- .../taskexecutor/GridHadoopExecutorService.java | 2 +- .../hadoop/v2/GridHadoopSplitWrapper.java | 3 +- .../processors/hadoop/GridHadoopGroupingTest.java | 10 +++--- .../hadoop/GridHadoopJobTrackerSelfTest.java | 2 +- .../processors/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 +-- .../IgniteProjectionStartStopRestartSelfTest.java | 3 +- 83 files changed, 181 insertions(+), 280 deletions(-) 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."); 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)) 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> tasks = new ArrayList<>(); IgniteCompute comp = parent.compute().withAsync(); 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 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()); } 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 extends GridCacheManagerAdapter { cctx.affinity().backupPartitions(cctx.localNodeId(), topVer); return new PartitionsIterator(parts) { - @Override protected GridCloseableIterator> partitionIterator(int part) - throws IgniteCheckedException - { + @Override protected GridCloseableIterator> partitionIterator(int part) { return offheap.iterator(spaceName, part); } }; 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 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 req) - throws ClassNotFoundException { + @Nullable private GridCacheQueryInfo distributedQueryInfo(UUID sndId, GridCacheQueryRequest req) { IgnitePredicate> prjPred = req.projectionFilter() == null ? F.>alwaysTrue() : req.projectionFilter(); 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 extends GridCacheManagerAdapte sendTtlUpdate(); } - @Override protected void onClose() throws IgniteCheckedException { + @Override protected void onClose() { sendTtlUpdate(); } 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 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 ldr = flushQ.take(); 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; 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 res) - throws IgniteCheckedException { + private void affinity0(IgfsFileInfo info, long start, long len, long maxLen, Deque res) { long firstGrpIdx = start / grpBlockSize; long limitGrpIdx = (start + len + grpBlockSize - 1) / grpBlockSize; 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 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(); 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; 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() { - @Nullable @Override public Object call() throws IgniteCheckedException { + @Nullable @Override public Object call() { try { if (internal && ctx.config().isPeerClassLoadingEnabled()) ctx.job().internal(true); 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 extends GridWorker implements GridTimeoutObject { Map mappedJobs = U.wrapThreadLoader(dep.classLoader(), new Callable>() { - @Override public Map call() throws IgniteCheckedException { + @Override public Map call() { return task.map(shuffledNodes, arg); } }); @@ -902,7 +902,7 @@ class GridTaskWorker extends GridWorker implements GridTimeoutObject { try { // Reduce results. reduceRes = U.wrapThreadLoader(dep.classLoader(), new Callable() { - @Nullable @Override public R call() throws IgniteCheckedException { + @Nullable @Override public R call() { return task.reduce(results); } }); 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 ea73ca6..d9eb35d 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 @@ -8408,13 +8408,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 resolveAddresses( AddressResolver addrRslvr, Iterable addrs, int port - ) throws IgniteCheckedException { + ) throws IgniteSpiException { assert addrRslvr != null; Collection extAddrs = new HashSet<>(); 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> futs) throws IgniteCheckedException { + public static void waitAll(@Nullable Iterable> futs) { if (F.isEmpty(futs)) return; 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(); } }; 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 7501a66..7fdb97c 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 extAddrs = addrRslvr == null ? null : - U.resolveAddresses(addrRslvr, F.flat(Arrays.asList(addrs.get1(), addrs.get2())), - locNode.discoveryPort()); + Collection 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); 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> rawIterator( final Iterator> iter) { return new GridCloseableIteratorAdapter>() { - @Override protected Map.Entry onNext() throws IgniteCheckedException { + @Override protected Map.Entry onNext() { Map.Entry x = iter.next(); return new T2<>(keyBytes(x.getKey()), x.getValue()); 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); 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>() { - @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>() { - @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>() { - @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>() { - @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>() { - @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>() { - @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>() { - @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>() { - @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>() { - @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>() { - @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>() { - @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>() { - @Override public IgniteFuture applyx(ClusterGroup prj) throws IgniteCheckedException { + @Override public IgniteFuture applyx(ClusterGroup prj) { IgniteCompute comp = compute(prj).withAsync(); CacheAffinity aff = prj.ignite().affinity(null); 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>() { - @Override public void applyx(IgniteFuture f) throws IgniteCheckedException { + @Override public void applyx(IgniteFuture f) { try { assert f.get(); } 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()); 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."); 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; } 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 c5b4dc8..122e299 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 @@ -3560,7 +3560,7 @@ public abstract class GridCacheAbstractFullApiSelfTest extends GridCacheAbstract }); CU.inTx(ignite(0), jcache(), concurrency, isolation, new CIX1>() { - @Override public void applyx(IgniteCache cache) throws IgniteCheckedException { + @Override public void applyx(IgniteCache cache) { for (int i = 0; i < cnt; i++) assertTrue(cache.remove("key" + i)); } 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, Object> cache = ((IgniteKernal)ignite).cache(null); // // CacheAffinityKey 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 Object get(String cacheKey, String terminalId) throws IgniteCheckedException { + private Object get(String cacheKey, String terminalId) { Object key = new CacheAffinityKey<>(cacheKey, terminalId); return (T) ignite.jcache(null).get(key); 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 findAbsentKeys(Ignite workerNode, - Collection keys) throws IgniteCheckedException { - + private Collection findAbsentKeys(Ignite workerNode, Collection keys) { Collection ret = new ArrayList<>(keys.size()); IgniteCache cache = workerNode.jcache(CACHE_NAME); 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 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 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 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)); 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() { - @Override public String call() throws IgniteCheckedException { + @Override public String call() { IgniteAtomicReference 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() { - @Override public String call() throws IgniteCheckedException { + @Override public String call() { IgniteAtomicReference 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() { - @Override public String call() throws IgniteCheckedException { + @Override public String call() { IgniteAtomicReference 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() { - @Override public String call() throws IgniteCheckedException { + @Override public String call() { IgniteAtomicStamped 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() { - @Override public String call() throws IgniteCheckedException { + @Override public String call() { IgniteAtomicStamped 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() { - @Override public String call() throws IgniteCheckedException { + @Override public String call() { IgniteAtomicStamped stamped = ignite.atomicStamped(stampedName, val, stamp, true); assertEquals(newVal, stamped.value()); 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); 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++) 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() { - @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() { - @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() { - @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() { - @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() { - @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() { - @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() { - @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() { - @Override public void apply(IgniteAtomicSequence t) throws IgniteCheckedException { + @Override public void apply(IgniteAtomicSequence t) { t.getAndAdd(2); t.addAndGet(3); t.addAndGet(5); 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() { - @Override public Void call() throws IgniteCheckedException { + @Override public Void call() { Ignite ignite = grid(0); IgniteQueue queue = ignite.queue(queueName, 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 cache = ignite.jcache(null); try (Transaction tx = ignite.transactions().txStart(concur, isolation)) { 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 cache = jcache(i); 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); } 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 cache = g.jcache("partitioned"); 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 ldr = g.dataLoader(null)) { // Sets max values to 1 so cache metrics have correct values. ldr.perNodeParallelLoadOperations(1); 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 c = grid(0).jcache(null); for (int i = 0; i < TX_CNT; i++) { 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++) { 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 p) - throws IgniteCheckedException { + private ComputeTaskFuture runAsync(int idx, IgniteRunnable job, @Nullable IgnitePredicate 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 p) - throws IgniteCheckedException { + private ComputeTaskFuture broadcast(int idx, IgniteRunnable job, @Nullable IgnitePredicate 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> broadcast(int idx, IgniteCallable job, - @Nullable IgnitePredicate p) throws IgniteCheckedException { + @Nullable IgnitePredicate 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> callAsync(int idx, Collection jobs, - @Nullable IgnitePredicate p) throws IgniteCheckedException { + @Nullable IgnitePredicate p) { assert idx >= 0 && idx < NODES_CNT; assert !F.isEmpty(jobs); 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 { 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 files = igfs.listFiles(new IgfsPath(path)); List names = new ArrayList<>(item.length); 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> applyx(String stageName, StreamerContext ctx, - Collection evts) throws IgniteCheckedException { + Collection evts) { assert evts.size() == 1; if (ctx.nextStageName() == null) { 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> applyx(String stageName, StreamerContext ctx, - Collection evts) throws IgniteCheckedException { + Collection evts) { String nextStage = ctx.nextStageName(); ctx.window().enqueueAll(evts); 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 longWriteClos = new CIX1() { - @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 longReadClos = new CIX1() { - @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 refWriteClos = new CIX1() { - @Override public void applyx(Ignite ignite) - throws IgniteCheckedException { + @Override public void applyx(Ignite ignite) { IgniteAtomicReference 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 refReadClos = new CIX1() { - @Override public void applyx(Ignite ignite) - throws IgniteCheckedException { + @Override public void applyx(Ignite ignite) { IgniteAtomicReference 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 seqWriteClos = new CIX1() { - @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 seqReadClos = new CIX1() { - @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 stampWriteClos = new CIX1() { - @Override public void applyx(Ignite ignite) - throws IgniteCheckedException { + @Override public void applyx(Ignite ignite) { IgniteAtomicStamped 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 stampReadClos = new CIX1() { - @Override public void applyx(Ignite ignite) - throws IgniteCheckedException { + @Override public void applyx(Ignite ignite) { IgniteAtomicStamped 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 queueWriteClos = new CIX1() { - @Override public void applyx(Ignite ignite) - throws IgniteCheckedException { + @Override public void applyx(Ignite ignite) { IgniteQueue 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 queueReadClos = new CIX1() { - @Override public void applyx(Ignite ignite) - throws IgniteCheckedException { + @Override public void applyx(Ignite ignite) { IgniteQueue 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 latchWriteClos = new CIX1() { - @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 latchReadClos = new CIX1() { - @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++) { 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> writeClos = new CIX1>() { - @Override public void applyx(IgniteCache cache) - throws IgniteCheckedException { + @Override public void applyx(IgniteCache 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> readClos = new CIX1>() { - @Override public void applyx(IgniteCache cache) - throws IgniteCheckedException { + @Override public void applyx(IgniteCache cache) { for (int i = 0; i < operationsPerTx; i++) { int k = RAND.nextInt(KEY_RANGE); 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 cache = g.jcache(null); assert cache != null; 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 cache) throws IgniteCheckedException { + private static void loadFromStore(IgniteCache cache) { cache.loadCache(null, 0, GridTestConstants.LOAD_THREADS, GridTestConstants.ENTRY_COUNT); } 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; 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()); } 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 ldr = g.dataLoader(null); 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 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 Object get(Object key) throws IgniteCheckedException { + private Object get(Object key) { return ignite.jcache(cacheName).get(key); } } 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() { - @Override public Object call() throws IgniteCheckedException { + @Override public Object call() { g.compute().execute(GridJobExecutionLoadTestTask.class, null); return null; 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; 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( 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."); 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 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 evictFut = runMultiThreadedAsync(new CAX() { - @Override public void applyx() throws IgniteCheckedException { + @Override public void applyx() { while (!Thread.currentThread().isInterrupted()) { win.pollEvicted(); 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 store) throws IgniteCheckedException { + private static Ignite start(CacheStore store) { IgniteConfiguration cfg = new IgniteConfiguration(); cfg.setLocalHost("127.0.0.1"); 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(); 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(); 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(); 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 allNodes, - List orderedNodes, ComputeTaskSession ses) throws IgniteCheckedException { + List 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 allNodes, - List orderedNodes, ComputeTaskSession ses1, ComputeTaskSession ses2) throws IgniteCheckedException { + List orderedNodes, ComputeTaskSession ses1, ComputeTaskSession ses2) { ClusterNode firstNode = spi.getBalancedNode(ses1, allNodes, new GridTestJob()); 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 updater) throws IgniteCheckedException { + private void checkIndexUpdater(StreamerIndexUpdater updater) { List> 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 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 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 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 idx) throws IgniteCheckedException { + private void checkNonUniqueIndex(StreamerIndexProvider idx) { assert !idx.isUnique(); StreamerBoundedSizeWindow win = new StreamerBoundedSizeWindow<>(); @@ -511,9 +509,8 @@ public class GridStreamerIndexSelfTest extends GridCommonAbstractTest { /** * @param idx Index. - * @throws IgniteCheckedException If failed. */ - private void checkUniqueIndex(StreamerIndexProvider idx) throws IgniteCheckedException { + private void checkUniqueIndex(StreamerIndexProvider idx) { assert idx.isUnique(); StreamerBoundedSizeWindow win = new StreamerBoundedSizeWindow<>(); 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 win, int maxSize) throws IgniteCheckedException { + private void finalChecks(StreamerWindow win, int maxSize) { int evictQueueSize = win.evictionQueueSize(); info("Eviction queue size for final checks: " + evictQueueSize); 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() { @Override public IgfsHandshakeResponse apply(IgfsHadoopEx hadoop, - IgfsHandshakeResponse hndResp) throws IgniteCheckedException, IOException { + IgfsHandshakeResponse hndResp) { return hndResp; } }); 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( " __________ ________________ ", " / _/ ___/ |/ / _/_ __/ __/ ", 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 reducers(Collection top, - Map> mappers, int reducerCnt) throws IgniteCheckedException { + Map> mappers, int reducerCnt) { // Determine initial node weights. int totalWeight = 0; 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(); } 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; 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. } }; 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; } 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. } }; 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"); } 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( 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(); 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 dimCache = ((IgniteKernal)ignite).cache("replicated"); 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 dimCache = ((IgniteKernal)ignite).cache("replicated"); 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()) + 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> startNodes(IgniteCluster cluster, Collection> hosts, @Nullable Map dflts, boolean restart, int timeout, - int maxConn) throws IgniteCheckedException { + int maxConn) { cluster = cluster.withAsync(); assertNull(cluster.startNodes(hosts, dflts, restart, timeout, maxConn)); -- 1.9.4.msysgit.0