ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From akuznet...@apache.org
Subject [31/41] incubator-ignite git commit: ignite-272 review
Date Thu, 26 Feb 2015 13:26:37 GMT
ignite-272 review


Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/7423b7cb
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/7423b7cb
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/7423b7cb

Branch: refs/heads/ignite-187
Commit: 7423b7cb3b27e68abcb03103a9a998d7e483cf74
Parents: 7bf5403
Author: Yakov Zhdanov <yzhdanov@gridgain.com>
Authored: Wed Feb 25 21:41:37 2015 +0300
Committer: Yakov Zhdanov <yzhdanov@gridgain.com>
Committed: Wed Feb 25 21:41:38 2015 +0300

----------------------------------------------------------------------
 .../IgniteCountDownLatchExample.java            |  3 +-
 .../MessagingPingPongListenActorExample.java    |  3 +-
 .../checkpoint/s3/S3CheckpointSpiSelfTest.java  | 10 +++---
 .../internal/client/ClientStartNodeTask.java    |  5 ++-
 .../processors/rest/RestProcessorTest.java      |  8 ++---
 .../processors/cache/GridCacheSwapManager.java  |  4 +--
 .../query/GridCacheDistributedQueryManager.java |  4 +--
 .../cache/query/GridCacheQueryManager.java      |  2 +-
 .../dataload/GridDataLoaderProcessor.java       |  2 +-
 .../datastructures/DataStructuresProcessor.java |  2 +-
 .../processors/igfs/IgfsDataManager.java        |  4 +--
 .../internal/processors/igfs/IgfsImpl.java      |  6 ++--
 .../processors/igfs/IgfsOutputStreamImpl.java   |  4 +--
 .../internal/processors/job/GridJobWorker.java  |  2 +-
 .../processors/task/GridTaskWorker.java         |  4 +--
 .../ignite/internal/util/IgniteUtils.java       |  4 +--
 .../apache/ignite/internal/util/typedef/X.java  |  3 +-
 .../ignite/spi/IgniteSpiThreadFactory.java      |  2 +-
 .../spi/discovery/tcp/TcpDiscoverySpi.java      | 17 ++++-----
 .../spi/swapspace/file/FileSwapSpaceSpi.java    |  2 +-
 .../internal/GridEventStorageSelfTest.java      |  3 +-
 .../GridJobMasterLeaveAwareSelfTest.java        | 24 ++++++-------
 .../internal/GridMultipleJobsSelfTest.java      |  2 +-
 .../GridTaskContinuousMapperSelfTest.java       |  3 +-
 .../GridTaskExecutionContextSelfTest.java       |  2 +-
 .../GridCheckpointManagerAbstractSelfTest.java  | 20 +++++------
 .../cache/GridCacheAbstractFullApiSelfTest.java |  2 +-
 .../GridCacheConcurrentTxMultiNodeTest.java     | 11 +++---
 .../cache/GridCachePutAllFailoverSelfTest.java  |  5 +--
 .../cache/IgniteTxMultiNodeAbstractTest.java    | 33 +++++-------------
 ...cheAtomicReferenceMultiNodeAbstractTest.java | 12 +++----
 .../GridCacheMultiNodeDataStructureTest.java    |  3 +-
 ...dCacheSequenceMultiNodeAbstractSelfTest.java |  2 +-
 ...titionedAtomicSequenceMultiThreadedTest.java | 16 ++++-----
 ...dCachePartitionedQueueEntryMoveSelfTest.java |  2 +-
 .../GridCacheAbstractJobExecutionTest.java      |  2 +-
 .../distributed/GridCacheEventAbstractTest.java |  4 +--
 .../dht/GridCacheDhtInternalEntrySelfTest.java  |  6 ++--
 .../dht/GridCacheDhtMultiBackupTest.java        |  2 +-
 ...idCachePartitionedHitsAndMissesSelfTest.java |  3 +-
 ...ePartitionedMultiThreadedPutGetSelfTest.java |  2 +-
 .../GridCacheRandomEvictionPolicySelfTest.java  |  2 +-
 .../closure/GridClosureProcessorSelfTest.java   | 14 +++-----
 .../processors/igfs/IgfsAbstractSelfTest.java   |  5 ++-
 .../processors/igfs/IgfsProcessorSelfTest.java  |  3 +-
 .../streamer/GridStreamerEvictionSelfTest.java  |  2 +-
 .../streamer/GridStreamerSelfTest.java          |  2 +-
 .../cache/GridCacheDataStructuresLoadTest.java  | 36 +++++++-------------
 .../loadtests/cache/GridCacheLoadTest.java      |  6 ++--
 .../loadtests/cache/GridCacheSwapLoadTest.java  |  5 ++-
 .../loadtests/colocation/GridTestMain.java      |  3 +-
 .../communication/GridIoManagerBenchmark.java   |  3 +-
 .../GridMultiSplitsRedeployLoadTest.java        |  5 ++-
 .../loadtests/discovery/GridGcTimeoutTest.java  |  3 +-
 .../ignite/loadtests/dsi/GridDsiPerfJob.java    | 13 +++----
 .../job/GridJobExecutionSingleNodeLoadTest.java |  2 +-
 .../mapper/GridContinuousMapperLoadTest1.java   |  3 +-
 .../loadtests/mapper/GridNodeStartup.java       |  3 +-
 .../mergesort/GridMergeSortLoadTest.java        |  3 +-
 .../streamer/GridStreamerIndexLoadTest.java     |  4 +--
 .../swap/GridSwapEvictAllBenchmark.java         |  3 +-
 ...idSessionFutureWaitJobAttributeSelfTest.java |  3 +-
 .../GridSessionSetTaskAttributeSelfTest.java    |  3 +-
 ...GridSessionTaskWaitJobAttributeSelfTest.java |  3 +-
 .../roundrobin/GridRoundRobinTestUtils.java     |  6 ++--
 .../index/GridStreamerIndexSelfTest.java        | 17 ++++-----
 .../window/GridStreamerWindowSelfTest.java      |  3 +-
 .../cache/GridAbstractCacheStoreSelfTest.java   |  3 +-
 .../internal/igfs/hadoop/IgfsHadoopWrapper.java |  2 +-
 .../processors/hadoop/GridHadoopSetup.java      |  3 +-
 .../GridHadoopDefaultMapReducePlanner.java      |  3 +-
 .../taskexecutor/GridHadoopExecutorService.java |  2 +-
 .../hadoop/v2/GridHadoopSplitWrapper.java       |  3 +-
 .../hadoop/GridHadoopGroupingTest.java          | 10 +++---
 .../hadoop/GridHadoopJobTrackerSelfTest.java    |  2 +-
 .../hadoop/GridHadoopSortingTest.java           |  9 +++--
 .../processors/hadoop/GridHadoopStartup.java    |  2 +-
 .../ignite/loadtests/igfs/IgfsNodeStartup.java  |  3 +-
 .../GridHibernateReadWriteAccessStrategy.java   |  5 ++-
 .../cache/GridCacheCrossCacheQuerySelfTest.java |  2 +-
 .../GridCacheCrossCacheQuerySelfTestNewApi.java |  2 +-
 .../p2p/GridP2PUserVersionChangeSelfTest.java   |  4 +--
 ...gniteProjectionStartStopRestartSelfTest.java |  3 +-
 83 files changed, 182 insertions(+), 281 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteCountDownLatchExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteCountDownLatchExample.java b/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteCountDownLatchExample.java
index 8cca611..dc5f608 100644
--- a/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteCountDownLatchExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteCountDownLatchExample.java
@@ -40,9 +40,8 @@ public class IgniteCountDownLatchExample {
      * Executes example.
      *
      * @param args Command line arguments, none required.
-     * @throws IgniteCheckedException If example execution failed.
      */
-    public static void main(String[] args) throws IgniteCheckedException {
+    public static void main(String[] args) {
         try (Ignite ignite = Ignition.start("examples/config/example-cache.xml")) {
             System.out.println();
             System.out.println(">>> Cache atomic countdown latch example started.");

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/examples/src/main/java/org/apache/ignite/examples/messaging/MessagingPingPongListenActorExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/messaging/MessagingPingPongListenActorExample.java b/examples/src/main/java/org/apache/ignite/examples/messaging/MessagingPingPongListenActorExample.java
index b498609..feeb56a 100644
--- a/examples/src/main/java/org/apache/ignite/examples/messaging/MessagingPingPongListenActorExample.java
+++ b/examples/src/main/java/org/apache/ignite/examples/messaging/MessagingPingPongListenActorExample.java
@@ -41,9 +41,8 @@ public class MessagingPingPongListenActorExample {
      * Executes example.
      *
      * @param args Command line arguments, none required.
-     * @throws IgniteCheckedException If example execution failed.
      */
-    public static void main(String[] args) throws IgniteCheckedException {
+    public static void main(String[] args) {
         // Game is played over the default ignite.
         try (Ignite ignite = Ignition.start("examples/config/example-compute.xml")) {
             if (!ExamplesUtils.checkMinTopologySize(ignite.cluster(), 2))

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/aws/src/test/java/org/apache/ignite/spi/checkpoint/s3/S3CheckpointSpiSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/aws/src/test/java/org/apache/ignite/spi/checkpoint/s3/S3CheckpointSpiSelfTest.java b/modules/aws/src/test/java/org/apache/ignite/spi/checkpoint/s3/S3CheckpointSpiSelfTest.java
index 9010f62..c257f16 100644
--- a/modules/aws/src/test/java/org/apache/ignite/spi/checkpoint/s3/S3CheckpointSpiSelfTest.java
+++ b/modules/aws/src/test/java/org/apache/ignite/spi/checkpoint/s3/S3CheckpointSpiSelfTest.java
@@ -100,7 +100,7 @@ public class S3CheckpointSpiSelfTest extends GridSpiAbstractTest<S3CheckpointSpi
             final String key = KEY_PREFIX + i;
 
             assertWithRetries(new GridAbsClosureX() {
-                @Override public void applyx() throws IgniteCheckedException {
+                @Override public void applyx() {
                     assertNotNull("Missing checkpoint: " + key,
                         getSpi().loadCheckpoint(key));
                 }
@@ -133,7 +133,7 @@ public class S3CheckpointSpiSelfTest extends GridSpiAbstractTest<S3CheckpointSpi
             final String key = KEY_PREFIX + i;
 
             assertWithRetries(new GridAbsClosureX() {
-                @Override public void applyx() throws IgniteCheckedException {
+                @Override public void applyx() {
                     assertNull(getSpi().loadCheckpoint(key));
                 }
             });
@@ -159,7 +159,7 @@ public class S3CheckpointSpiSelfTest extends GridSpiAbstractTest<S3CheckpointSpi
             final String key = KEY_PREFIX + i;
 
             assertWithRetries(new GridAbsClosureX() {
-                @Override public void applyx() throws IgniteCheckedException {
+                @Override public void applyx() {
                     assertNull("Checkpoint state should not be loaded with key: " + key,
                         getSpi().loadCheckpoint(key));
                 }
@@ -181,7 +181,7 @@ public class S3CheckpointSpiSelfTest extends GridSpiAbstractTest<S3CheckpointSpi
         getSpi().saveCheckpoint(KEY_PREFIX, GridTestIoUtils.serializeJdk(state2), 0, true);
 
         assertWithRetries(new GridAbsClosureX() {
-            @Override public void applyx() throws IgniteCheckedException {
+            @Override public void applyx() {
                 assertNotNull(getSpi().loadCheckpoint(KEY_PREFIX));
             }
         });
@@ -197,7 +197,7 @@ public class S3CheckpointSpiSelfTest extends GridSpiAbstractTest<S3CheckpointSpi
         getSpi().removeCheckpoint(KEY_PREFIX);
 
         assertWithRetries(new GridAbsClosureX() {
-            @Override public void applyx() throws IgniteCheckedException {
+            @Override public void applyx() {
                 assertNull(getSpi().loadCheckpoint(KEY_PREFIX));
             }
         });

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/clients/src/test/java/org/apache/ignite/internal/client/ClientStartNodeTask.java
----------------------------------------------------------------------
diff --git a/modules/clients/src/test/java/org/apache/ignite/internal/client/ClientStartNodeTask.java b/modules/clients/src/test/java/org/apache/ignite/internal/client/ClientStartNodeTask.java
index 006c168..1822790 100644
--- a/modules/clients/src/test/java/org/apache/ignite/internal/client/ClientStartNodeTask.java
+++ b/modules/clients/src/test/java/org/apache/ignite/internal/client/ClientStartNodeTask.java
@@ -131,7 +131,7 @@ public class ClientStartNodeTask extends TaskSingleJobSplitAdapter<String, Integ
 
             assert G.allGrids().isEmpty();
         }
-        catch (IgniteCheckedException e) {
+        catch (Exception e) {
             System.err.println("Uncaught exception: " + e.getMessage());
 
             e.printStackTrace(System.err);
@@ -145,9 +145,8 @@ public class ClientStartNodeTask extends TaskSingleJobSplitAdapter<String, Integ
      * @param add New nodes count.
      * @param rmv Remove nodes count.
      * @param type Type of nodes to manipulate.
-     * @throws IgniteCheckedException On any exception.
      */
-    private static void changeTopology(Ignite parent, int add, int rmv, String type) throws IgniteCheckedException {
+    private static void changeTopology(Ignite parent, int add, int rmv, String type) {
         Collection<ComputeTaskFuture<?>> tasks = new ArrayList<>();
 
         IgniteCompute comp = parent.compute().withAsync();

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/clients/src/test/java/org/apache/ignite/internal/processors/rest/RestProcessorTest.java
----------------------------------------------------------------------
diff --git a/modules/clients/src/test/java/org/apache/ignite/internal/processors/rest/RestProcessorTest.java b/modules/clients/src/test/java/org/apache/ignite/internal/processors/rest/RestProcessorTest.java
index 0a45d45..1c61c75 100644
--- a/modules/clients/src/test/java/org/apache/ignite/internal/processors/rest/RestProcessorTest.java
+++ b/modules/clients/src/test/java/org/apache/ignite/internal/processors/rest/RestProcessorTest.java
@@ -132,9 +132,9 @@ public class RestProcessorTest extends GridCommonAbstractTest {
     }
 
     /**
-     * @throws IgniteCheckedException If failed.
+     *
      */
-    private void populateCache() throws IgniteCheckedException {
+    private void populateCache() {
         IgniteCache<String, Object> cache = G.ignite().jcache(null);
 
         cache.put("int", intValue());
@@ -152,9 +152,9 @@ public class RestProcessorTest extends GridCommonAbstractTest {
     }
 
     /**
-     * @throws IgniteCheckedException If failed.
+     *
      */
-    private void deployTasks() throws IgniteCheckedException {
+    private void deployTasks() {
         G.ignite().compute().localDeployTask(TestTask1.class, TestTask1.class.getClassLoader());
         G.ignite().compute().localDeployTask(TestTask2.class, TestTask2.class.getClassLoader());
     }

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheSwapManager.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheSwapManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheSwapManager.java
index 0a7b768..c1c8b0d 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheSwapManager.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheSwapManager.java
@@ -1560,9 +1560,7 @@ public class GridCacheSwapManager<K, V> extends GridCacheManagerAdapter<K, V> {
             cctx.affinity().backupPartitions(cctx.localNodeId(), topVer);
 
         return new PartitionsIterator(parts) {
-            @Override protected GridCloseableIterator<? extends Map.Entry<byte[], byte[]>> partitionIterator(int part)
-                throws IgniteCheckedException
-            {
+            @Override protected GridCloseableIterator<? extends Map.Entry<byte[], byte[]>> partitionIterator(int part) {
                 return offheap.iterator(spaceName, part);
             }
         };

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheDistributedQueryManager.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheDistributedQueryManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheDistributedQueryManager.java
index c08f047..c9ef668 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheDistributedQueryManager.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheDistributedQueryManager.java
@@ -193,10 +193,8 @@ public class GridCacheDistributedQueryManager<K, V> extends GridCacheQueryManage
      * @param sndId Sender node id.
      * @param req Query request.
      * @return Query info.
-     * @throws ClassNotFoundException If class not found.
      */
-    @Nullable private GridCacheQueryInfo distributedQueryInfo(UUID sndId, GridCacheQueryRequest<K, V> req)
-        throws ClassNotFoundException {
+    @Nullable private GridCacheQueryInfo distributedQueryInfo(UUID sndId, GridCacheQueryRequest<K, V> req) {
         IgnitePredicate<Cache.Entry<Object, Object>> prjPred = req.projectionFilter() == null ?
             F.<Cache.Entry<Object, Object>>alwaysTrue() : req.projectionFilter();
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryManager.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryManager.java
index 362077f..8fa48aa 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryManager.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryManager.java
@@ -833,7 +833,7 @@ public abstract class GridCacheQueryManager<K, V> extends GridCacheManagerAdapte
                     sendTtlUpdate();
             }
 
-            @Override protected void onClose() throws IgniteCheckedException {
+            @Override protected void onClose() {
                 sendTtlUpdate();
             }
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/main/java/org/apache/ignite/internal/processors/dataload/GridDataLoaderProcessor.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/dataload/GridDataLoaderProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/dataload/GridDataLoaderProcessor.java
index acac20d..d470d02 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/dataload/GridDataLoaderProcessor.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/dataload/GridDataLoaderProcessor.java
@@ -78,7 +78,7 @@ public class GridDataLoaderProcessor<K, V> extends GridProcessorAdapter {
             return;
 
         flusher = new IgniteThread(new GridWorker(ctx.gridName(), "grid-data-loader-flusher", log) {
-            @Override protected void body() throws InterruptedException, IgniteInterruptedCheckedException {
+            @Override protected void body() throws InterruptedException {
                 while (!isCancelled()) {
                     IgniteDataLoaderImpl<K, V> ldr = flushQ.take();
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/DataStructuresProcessor.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/DataStructuresProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/DataStructuresProcessor.java
index a2d69fb..6ae7188 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/DataStructuresProcessor.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/DataStructuresProcessor.java
@@ -105,7 +105,7 @@ public final class DataStructuresProcessor extends GridProcessorAdapter {
 
     /** {@inheritDoc} */
     @SuppressWarnings("unchecked")
-    @Override public void start() throws IgniteCheckedException {
+    @Override public void start() {
         if (ctx.config().isDaemon())
             return;
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDataManager.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDataManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDataManager.java
index d2f4f23..e960422 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDataManager.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDataManager.java
@@ -859,10 +859,8 @@ public class IgfsDataManager extends IgfsManager {
      * @param len Length.
      * @param maxLen Maximum allowed split length.
      * @param res Result collection to add regions to.
-     * @throws IgniteCheckedException If failed.
      */
-    private void affinity0(IgfsFileInfo info, long start, long len, long maxLen, Deque<IgfsBlockLocation> res)
-        throws IgniteCheckedException {
+    private void affinity0(IgfsFileInfo info, long start, long len, long maxLen, Deque<IgfsBlockLocation> res) {
         long firstGrpIdx = start / grpBlockSize;
         long limitGrpIdx = (start + len + grpBlockSize - 1) / grpBlockSize;
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsImpl.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsImpl.java
index cb27cc9..eff987e 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsImpl.java
@@ -397,7 +397,7 @@ public final class IgfsImpl implements IgfsEx {
 
     /** {@inheritDoc} */
     @SuppressWarnings("ConstantConditions")
-    @Override public IgfsStatus globalSpace() throws IgniteCheckedException {
+    @Override public IgfsStatus globalSpace() {
         if (enterBusy()) {
             try {
                 IgniteBiTuple<Long, Long> space = igfsCtx.kernalContext().grid().compute().execute(
@@ -1992,11 +1992,9 @@ public final class IgfsImpl implements IgfsEx {
          * @param bufSize The size of the buffer to be used.
          * @param mode IGFS mode.
          * @param batch Optional secondary file system batch.
-         * @throws IgniteCheckedException In case of error.
          */
         IgfsEventAwareOutputStream(IgfsPath path, IgfsFileInfo fileInfo,
-            IgniteUuid parentId, int bufSize, IgfsMode mode, @Nullable IgfsFileWorkerBatch batch)
-            throws IgniteCheckedException {
+            IgniteUuid parentId, int bufSize, IgfsMode mode, @Nullable IgfsFileWorkerBatch batch) {
             super(igfsCtx, path, fileInfo, parentId, bufSize, mode, batch, metrics);
 
             metrics.incrementFilesOpenedForWrite();

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsOutputStreamImpl.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsOutputStreamImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsOutputStreamImpl.java
index 7a6d946..5941579 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsOutputStreamImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsOutputStreamImpl.java
@@ -96,11 +96,9 @@ class IgfsOutputStreamImpl extends IgfsOutputStreamAdapter {
      * @param mode Grid IGFS mode.
      * @param batch Optional secondary file system batch.
      * @param metrics Local IGFS metrics.
-     * @throws IgniteCheckedException If stream creation failed.
      */
     IgfsOutputStreamImpl(IgfsContext igfsCtx, IgfsPath path, IgfsFileInfo fileInfo, IgniteUuid parentId,
-        int bufSize, IgfsMode mode, @Nullable IgfsFileWorkerBatch batch, IgfsLocalMetrics metrics)
-        throws IgniteCheckedException {
+        int bufSize, IgfsMode mode, @Nullable IgfsFileWorkerBatch batch, IgfsLocalMetrics metrics) {
         super(path, optimizeBufferSize(bufSize, fileInfo));
 
         assert fileInfo != null;

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/main/java/org/apache/ignite/internal/processors/job/GridJobWorker.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/job/GridJobWorker.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/job/GridJobWorker.java
index e35bd47..fdfc5c8 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/job/GridJobWorker.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/job/GridJobWorker.java
@@ -470,7 +470,7 @@ public class GridJobWorker extends GridWorker implements GridTimeoutObject {
                 sndRes = false;
             else {
                 res = U.wrapThreadLoader(dep.classLoader(), new Callable<Object>() {
-                    @Nullable @Override public Object call() throws IgniteCheckedException {
+                    @Nullable @Override public Object call() {
                         try {
                             if (internal && ctx.config().isPeerClassLoadingEnabled())
                                 ctx.job().internal(true);

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskWorker.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskWorker.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskWorker.java
index 258537e..965a75e 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskWorker.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskWorker.java
@@ -411,7 +411,7 @@ class GridTaskWorker<T, R> extends GridWorker implements GridTimeoutObject {
 
             Map<? extends ComputeJob, ClusterNode> mappedJobs = U.wrapThreadLoader(dep.classLoader(),
                 new Callable<Map<? extends ComputeJob, ClusterNode>>() {
-                    @Override public Map<? extends ComputeJob, ClusterNode> call() throws IgniteCheckedException {
+                    @Override public Map<? extends ComputeJob, ClusterNode> call() {
                         return task.map(shuffledNodes, arg);
                     }
                 });
@@ -902,7 +902,7 @@ class GridTaskWorker<T, R> extends GridWorker implements GridTimeoutObject {
             try {
                 // Reduce results.
                 reduceRes = U.wrapThreadLoader(dep.classLoader(), new Callable<R>() {
-                    @Nullable @Override public R call() throws IgniteCheckedException {
+                    @Nullable @Override public R call() {
                         return task.reduce(results);
                     }
                 });

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteUtils.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteUtils.java b/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteUtils.java
index 1348bb5..e4b23f1 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteUtils.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteUtils.java
@@ -8406,13 +8406,13 @@ public abstract class IgniteUtils {
      * @param addrs Addresses.
      * @param port Port.
      * @return Resolved socket addresses.
-     * @throws IgniteCheckedException If failed.
+     * @throws IgniteSpiException If failed.
      */
     public static Collection<InetSocketAddress> resolveAddresses(
         AddressResolver addrRslvr,
         Iterable<String> addrs,
         int port
-    ) throws IgniteCheckedException {
+    ) throws IgniteSpiException {
         assert addrRslvr != null;
 
         Collection<InetSocketAddress> extAddrs = new HashSet<>();

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/main/java/org/apache/ignite/internal/util/typedef/X.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/typedef/X.java b/modules/core/src/main/java/org/apache/ignite/internal/util/typedef/X.java
index 63b0470..fe48475 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/util/typedef/X.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/util/typedef/X.java
@@ -764,9 +764,8 @@ public final class X {
      * Synchronously waits for all futures in the collection.
      *
      * @param futs Futures to wait for.
-     * @throws IgniteCheckedException If any of the futures threw exception.
      */
-    public static void waitAll(@Nullable Iterable<IgniteFuture<?>> futs) throws IgniteCheckedException {
+    public static void waitAll(@Nullable Iterable<IgniteFuture<?>> futs) {
         if (F.isEmpty(futs))
             return;
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/main/java/org/apache/ignite/spi/IgniteSpiThreadFactory.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/spi/IgniteSpiThreadFactory.java b/modules/core/src/main/java/org/apache/ignite/spi/IgniteSpiThreadFactory.java
index cda4b7e..2344d3f 100644
--- a/modules/core/src/main/java/org/apache/ignite/spi/IgniteSpiThreadFactory.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/IgniteSpiThreadFactory.java
@@ -53,7 +53,7 @@ public class IgniteSpiThreadFactory implements ThreadFactory {
     @Override public Thread newThread(final Runnable r) {
         return new IgniteSpiThread(gridName, threadName, log) {
             /** {@inheritDoc} */
-            @Override protected void body() throws InterruptedException {
+            @Override protected void body() {
                 r.run();
             }
         };

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java
index 59336ad..87aebc4 100644
--- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java
@@ -709,17 +709,12 @@ public class TcpDiscoverySpi extends TcpDiscoverySpiAdapter implements TcpDiscov
             metricsProvider,
             locNodeVer);
 
-        try {
-            Collection<InetSocketAddress> extAddrs = addrRslvr == null ? null :
-                U.resolveAddresses(addrRslvr, F.flat(Arrays.asList(addrs.get1(), addrs.get2())),
-                    locNode.discoveryPort());
+        Collection<InetSocketAddress> extAddrs = addrRslvr == null ? null :
+            U.resolveAddresses(addrRslvr, F.flat(Arrays.asList(addrs.get1(), addrs.get2())),
+                locNode.discoveryPort());
 
-            if (extAddrs != null)
-                locNodeAttrs.put(createSpiAttributeName(ATTR_EXT_ADDRS), extAddrs);
-        }
-        catch (IgniteCheckedException e) {
-            throw new IgniteSpiException("Failed to resolve local host to addresses: " + locHost, e);
-        }
+        if (extAddrs != null)
+            locNodeAttrs.put(createSpiAttributeName(ATTR_EXT_ADDRS), extAddrs);
 
         locNode.setAttributes(locNodeAttrs);
 
@@ -2874,7 +2869,7 @@ public class TcpDiscoverySpi extends TcpDiscoverySpiAdapter implements TcpDiscov
                                 U.error(log, "Failed to send message to next node [next=" + next.id() + ", msg=" + msg +
                                     ", err=" + e + ']', e);
 
-                            onException("Failed to send message to next node [next=" + next.id() + ", msg=" + msg + ']', 
+                            onException("Failed to send message to next node [next=" + next.id() + ", msg=" + msg + ']',
                                 e);
 
                             if (e instanceof SocketTimeoutException || X.hasCause(e, SocketTimeoutException.class)) {

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/main/java/org/apache/ignite/spi/swapspace/file/FileSwapSpaceSpi.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/spi/swapspace/file/FileSwapSpaceSpi.java b/modules/core/src/main/java/org/apache/ignite/spi/swapspace/file/FileSwapSpaceSpi.java
index ec2ef97..122d0ed 100644
--- a/modules/core/src/main/java/org/apache/ignite/spi/swapspace/file/FileSwapSpaceSpi.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/swapspace/file/FileSwapSpaceSpi.java
@@ -529,7 +529,7 @@ public class FileSwapSpaceSpi extends IgniteSpiAdapter implements SwapSpaceSpi,
     private IgniteSpiCloseableIterator<Map.Entry<byte[], byte[]>> rawIterator(
         final Iterator<Map.Entry<SwapKey, byte[]>> iter) {
         return new GridCloseableIteratorAdapter<Map.Entry<byte[], byte[]>>() {
-            @Override protected Map.Entry<byte[], byte[]> onNext() throws IgniteCheckedException {
+            @Override protected Map.Entry<byte[], byte[]> onNext() {
                 Map.Entry<SwapKey, byte[]> x = iter.next();
 
                 return new T2<>(keyBytes(x.getKey()), x.getValue());

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/GridEventStorageSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridEventStorageSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridEventStorageSelfTest.java
index 60a5f53..8748c73 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/GridEventStorageSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/GridEventStorageSelfTest.java
@@ -186,9 +186,8 @@ public class GridEventStorageSelfTest extends GridCommonAbstractTest {
      * Create events in grid.
      *
      * @param ignite Grid.
-     * @throws IgniteCheckedException In case of error.
      */
-    private void generateEvents(Ignite ignite) throws IgniteCheckedException {
+    private void generateEvents(Ignite ignite) {
         ignite.compute().localDeployTask(GridEventTestTask.class, GridEventTestTask.class.getClassLoader());
 
         ignite.compute().execute(GridEventTestTask.class.getName(), null);

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/GridJobMasterLeaveAwareSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridJobMasterLeaveAwareSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridJobMasterLeaveAwareSelfTest.java
index 57c45b7..fc5cf26 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/GridJobMasterLeaveAwareSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/GridJobMasterLeaveAwareSelfTest.java
@@ -253,7 +253,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest {
      */
     public void testApply1() throws Exception {
         testMasterLeaveAwareCallback(1, new CX1<ClusterGroup, IgniteFuture<?>>() {
-            @Override public IgniteFuture<?> applyx(ClusterGroup grid) throws IgniteCheckedException {
+            @Override public IgniteFuture<?> applyx(ClusterGroup grid) {
                 IgniteCompute comp = compute(grid).withAsync();
 
                 comp.apply(new TestClosure(), "arg");
@@ -268,7 +268,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest {
      */
     public void testApply2() throws Exception {
         testMasterLeaveAwareCallback(2, new CX1<ClusterGroup, IgniteFuture<?>>() {
-            @Override public IgniteFuture<?> applyx(ClusterGroup grid) throws IgniteCheckedException {
+            @Override public IgniteFuture<?> applyx(ClusterGroup grid) {
                 IgniteCompute comp = compute(grid).withAsync();
 
                 comp.apply(new TestClosure(), Arrays.asList("arg1", "arg2"));
@@ -283,7 +283,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest {
      */
     public void testApply3() throws Exception {
         testMasterLeaveAwareCallback(2, new CX1<ClusterGroup, IgniteFuture<?>>() {
-            @Override public IgniteFuture<?> applyx(ClusterGroup grid) throws IgniteCheckedException {
+            @Override public IgniteFuture<?> applyx(ClusterGroup grid) {
                 IgniteCompute comp = compute(grid).withAsync();
 
                 comp.apply(new TestClosure(),
@@ -308,7 +308,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest {
      */
     public void testRun1() throws Exception {
         testMasterLeaveAwareCallback(1, new CX1<ClusterGroup, IgniteFuture<?>>() {
-            @Override public IgniteFuture<?> applyx(ClusterGroup prj) throws IgniteCheckedException {
+            @Override public IgniteFuture<?> applyx(ClusterGroup prj) {
                 IgniteCompute comp = compute(prj).withAsync();
 
                 comp.run(new TestRunnable());
@@ -323,7 +323,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest {
      */
     public void testRun2() throws Exception {
         testMasterLeaveAwareCallback(2, new CX1<ClusterGroup, IgniteFuture<?>>() {
-            @Override public IgniteFuture<?> applyx(ClusterGroup prj) throws IgniteCheckedException {
+            @Override public IgniteFuture<?> applyx(ClusterGroup prj) {
                 IgniteCompute comp = compute(prj).withAsync();
 
                 comp.run(Arrays.asList(new TestRunnable(), new TestRunnable()));
@@ -338,7 +338,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest {
      */
     public void testCall1() throws Exception {
         testMasterLeaveAwareCallback(1, new CX1<ClusterGroup, IgniteFuture<?>>() {
-            @Override public IgniteFuture<?> applyx(ClusterGroup prj) throws IgniteCheckedException {
+            @Override public IgniteFuture<?> applyx(ClusterGroup prj) {
                 IgniteCompute comp = compute(prj).withAsync();
 
                 comp.call(new TestCallable());
@@ -353,7 +353,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest {
      */
     public void testCall2() throws Exception {
         testMasterLeaveAwareCallback(2, new CX1<ClusterGroup, IgniteFuture<?>>() {
-            @Override public IgniteFuture<?> applyx(ClusterGroup prj) throws IgniteCheckedException {
+            @Override public IgniteFuture<?> applyx(ClusterGroup prj) {
                 IgniteCompute comp = compute(prj).withAsync();
 
                 comp.call(Arrays.asList(new TestCallable(), new TestCallable()));
@@ -368,7 +368,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest {
      */
     public void testCall3() throws Exception {
         testMasterLeaveAwareCallback(2, new CX1<ClusterGroup, IgniteFuture<?>>() {
-            @Override public IgniteFuture<?> applyx(ClusterGroup prj) throws IgniteCheckedException {
+            @Override public IgniteFuture<?> applyx(ClusterGroup prj) {
                 IgniteCompute comp = compute(prj).withAsync();
 
                 comp.call(
@@ -393,7 +393,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest {
      */
     public void testBroadcast1() throws Exception {
         testMasterLeaveAwareCallback(1, new CX1<ClusterGroup, IgniteFuture<?>>() {
-            @Override public IgniteFuture<?> applyx(ClusterGroup prj) throws IgniteCheckedException {
+            @Override public IgniteFuture<?> applyx(ClusterGroup prj) {
                 IgniteCompute comp = compute(prj).withAsync();
 
                 comp.broadcast(new TestRunnable());
@@ -408,7 +408,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest {
      */
     public void testBroadcast2() throws Exception {
         testMasterLeaveAwareCallback(1, new CX1<ClusterGroup, IgniteFuture<?>>() {
-            @Override public IgniteFuture<?> applyx(ClusterGroup prj) throws IgniteCheckedException {
+            @Override public IgniteFuture<?> applyx(ClusterGroup prj) {
                 IgniteCompute comp = compute(prj).withAsync();
 
                 comp.broadcast(new TestCallable());
@@ -423,7 +423,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest {
      */
     public void testBroadcast3() throws Exception {
         testMasterLeaveAwareCallback(1, new CX1<ClusterGroup, IgniteFuture<?>>() {
-            @Override public IgniteFuture<?> applyx(ClusterGroup prj) throws IgniteCheckedException {
+            @Override public IgniteFuture<?> applyx(ClusterGroup prj) {
                 IgniteCompute comp = compute(prj).withAsync();
 
                 comp.broadcast(new TestClosure(), "arg");
@@ -438,7 +438,7 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest {
      */
     public void testAffinityRun() throws Exception {
         testMasterLeaveAwareCallback(1, new CX1<ClusterGroup, IgniteFuture<?>>() {
-            @Override public IgniteFuture<?> applyx(ClusterGroup prj) throws IgniteCheckedException {
+            @Override public IgniteFuture<?> applyx(ClusterGroup prj) {
                 IgniteCompute comp = compute(prj).withAsync();
 
                 CacheAffinity<Object> aff = prj.ignite().affinity(null);

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/GridMultipleJobsSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridMultipleJobsSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridMultipleJobsSelfTest.java
index 24a117c..565aaa7 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/GridMultipleJobsSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/GridMultipleJobsSelfTest.java
@@ -158,7 +158,7 @@ public class GridMultipleJobsSelfTest extends GridCommonAbstractTest {
                         X.println("Submitted jobs: " + cnt);
 
                     fut.listenAsync(new CIX1<IgniteFuture<Boolean>>() {
-                        @Override public void applyx(IgniteFuture<Boolean> f) throws IgniteCheckedException {
+                        @Override public void applyx(IgniteFuture<Boolean> f) {
                             try {
                                 assert f.get();
                             }

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/GridTaskContinuousMapperSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridTaskContinuousMapperSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridTaskContinuousMapperSelfTest.java
index e254957..3ae94b3 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/GridTaskContinuousMapperSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/GridTaskContinuousMapperSelfTest.java
@@ -133,11 +133,10 @@ public class GridTaskContinuousMapperSelfTest extends GridCommonAbstractTest {
 
         /**
          * @param mapper Continuous mapper.
-         * @throws IgniteCheckedException Thrown if any exception occurs.
          */
         @SuppressWarnings("unused")
         @TaskContinuousMapperResource
-        private void setMapper(ComputeTaskContinuousMapper mapper) throws IgniteCheckedException {
+        private void setMapper(ComputeTaskContinuousMapper mapper) {
             this.mapper = mapper;
 
             mapper.send(new TestJob());

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/GridTaskExecutionContextSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridTaskExecutionContextSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridTaskExecutionContextSelfTest.java
index 82db502..d16aa1f 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/GridTaskExecutionContextSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/GridTaskExecutionContextSelfTest.java
@@ -92,7 +92,7 @@ public class GridTaskExecutionContextSelfTest extends GridCommonAbstractTest {
      */
     public void testWithNoFailoverClosure() throws Exception {
         final IgniteRunnable r = new GridAbsClosureX() {
-            @Override public void applyx() throws IgniteCheckedException {
+            @Override public void applyx() {
                 CNT.incrementAndGet();
 
                 throw new ComputeExecutionRejectedException("Expected error.");

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/managers/checkpoint/GridCheckpointManagerAbstractSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/managers/checkpoint/GridCheckpointManagerAbstractSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/managers/checkpoint/GridCheckpointManagerAbstractSelfTest.java
index e31ae8e..e6c8889 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/managers/checkpoint/GridCheckpointManagerAbstractSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/managers/checkpoint/GridCheckpointManagerAbstractSelfTest.java
@@ -318,7 +318,7 @@ public abstract class GridCheckpointManagerAbstractSelfTest extends GridCommonAb
             taskSes.saveCheckpoint(key2, val2, SESSION_SCOPE, 0);
 
             assertWithRetries(new GridAbsClosureX() {
-                @Override public void applyx() throws IgniteCheckedException {
+                @Override public void applyx() {
                     assert val1.equals(taskSes.loadCheckpoint(key1));
                     assert val2.equals(taskSes.loadCheckpoint(key2));
                 }
@@ -329,7 +329,7 @@ public abstract class GridCheckpointManagerAbstractSelfTest extends GridCommonAb
             taskSes.saveCheckpoint(key2, val1, SESSION_SCOPE, 0, false);
 
             assertWithRetries(new GridAbsClosureX() {
-                @Override public void applyx() throws IgniteCheckedException {
+                @Override public void applyx() {
                     assert val1.equals(taskSes.loadCheckpoint(key1));
                     assert val2.equals(taskSes.loadCheckpoint(key2));
                 }
@@ -339,7 +339,7 @@ public abstract class GridCheckpointManagerAbstractSelfTest extends GridCommonAb
             taskSes.saveCheckpoint(key2, val1, SESSION_SCOPE, 0, true);
 
             assertWithRetries(new GridAbsClosureX() {
-                @Override public void applyx() throws IgniteCheckedException {
+                @Override public void applyx() {
                     assert val2.equals(taskSes.loadCheckpoint(key1));
                     assert val1.equals(taskSes.loadCheckpoint(key2));
                 }
@@ -351,7 +351,7 @@ public abstract class GridCheckpointManagerAbstractSelfTest extends GridCommonAb
             assert !taskSes.removeCheckpoint(key2);
 
             assertWithRetries(new GridAbsClosureX() {
-                @Override public void applyx() throws IgniteCheckedException {
+                @Override public void applyx() {
                     assert taskSes.loadCheckpoint(key1) == null;
                     assert taskSes.loadCheckpoint(key2) == null;
                 }
@@ -375,7 +375,7 @@ public abstract class GridCheckpointManagerAbstractSelfTest extends GridCommonAb
             }
 
             assertWithRetries(new GridAbsClosureX() {
-                @Override public void applyx() throws IgniteCheckedException {
+                @Override public void applyx() {
                     assert taskSes.loadCheckpoint(key1) == null;
                     assert taskSes.loadCheckpoint(key2) == null;
                 }
@@ -502,7 +502,7 @@ public abstract class GridCheckpointManagerAbstractSelfTest extends GridCommonAb
             rmvLatch.countDown();
 
             assertWithRetries(new GridAbsClosureX() {
-                @Override public void applyx() throws IgniteCheckedException {
+                @Override public void applyx() {
                     assert taskSes.loadCheckpoint(GLOBAL_KEY) == null;
                     assert taskSes.loadCheckpoint(SES_KEY) == null;
                 }
@@ -556,7 +556,7 @@ public abstract class GridCheckpointManagerAbstractSelfTest extends GridCommonAb
 
             // Test that checkpoints were saved properly.
             assertWithRetries(new GridAbsClosureX() {
-                @Override public void applyx() throws IgniteCheckedException {
+                @Override public void applyx() {
                     assert GLOBAL_VAL.equals(taskSes.loadCheckpoint(GLOBAL_KEY));
                     assert SES_VAL.equals(taskSes.loadCheckpoint(SES_KEY));
                 }
@@ -573,7 +573,7 @@ public abstract class GridCheckpointManagerAbstractSelfTest extends GridCommonAb
 
             // Test that checkpoints were not overwritten.
             assertWithRetries(new GridAbsClosureX() {
-                @Override public void applyx() throws IgniteCheckedException {
+                @Override public void applyx() {
                     assert GLOBAL_VAL.equals(taskSes.loadCheckpoint(GLOBAL_KEY));
                     assert SES_VAL.equals(taskSes.loadCheckpoint(SES_KEY));
                 }
@@ -589,7 +589,7 @@ public abstract class GridCheckpointManagerAbstractSelfTest extends GridCommonAb
             }
 
             assertWithRetries(new GridAbsClosureX() {
-                @Override public void applyx() throws IgniteCheckedException {
+                @Override public void applyx() {
                     assertEquals(SES_VAL_OVERWRITTEN, taskSes.loadCheckpoint(GLOBAL_KEY));
                     assertEquals(GLOBAL_VAL_OVERWRITTEN, taskSes.loadCheckpoint(SES_KEY));
                 }
@@ -608,7 +608,7 @@ public abstract class GridCheckpointManagerAbstractSelfTest extends GridCommonAb
             assert !taskSes.removeCheckpoint(SES_KEY);
 
             assertWithRetries(new GridAbsClosureX() {
-                @Override public void applyx() throws IgniteCheckedException {
+                @Override public void applyx() {
                     assert taskSes.loadCheckpoint(GLOBAL_KEY) == null;
                     assert taskSes.loadCheckpoint(SES_KEY) == null;
                 }

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java
index 3ab4544..43dc0ce 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java
@@ -3659,7 +3659,7 @@ public abstract class GridCacheAbstractFullApiSelfTest extends GridCacheAbstract
             });
 
             CU.inTx(ignite(0), jcache(), concurrency, isolation, new CIX1<IgniteCache<String, Integer>>() {
-                @Override public void applyx(IgniteCache<String, Integer> cache) throws IgniteCheckedException {
+                @Override public void applyx(IgniteCache<String, Integer> cache) {
                     for (int i = 0; i < cnt; i++)
                         assertTrue(cache.remove("key" + i));
                 }

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheConcurrentTxMultiNodeTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheConcurrentTxMultiNodeTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheConcurrentTxMultiNodeTest.java
index 6c21b28..d841063 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheConcurrentTxMultiNodeTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheConcurrentTxMultiNodeTest.java
@@ -658,16 +658,15 @@ public class GridCacheConcurrentTxMultiNodeTest extends GridCommonAbstractTest {
                     stopTimer("commit");
                 }
             }
-            catch (IgniteCheckedException e) {
+            catch (Exception e) {
                 e.printStackTrace();
             }
         }
 
         /**
          * @return New ID.
-         * @throws IgniteCheckedException If failed.
          */
-        private long getId() throws IgniteCheckedException {
+        private long getId() {
             IgniteAtomicSequence seq = ignite.atomicSequence("ID", 0, true);
 
             return seq.incrementAndGet();
@@ -705,9 +704,8 @@ public class GridCacheConcurrentTxMultiNodeTest extends GridCommonAbstractTest {
          * @param o Object to put.
          * @param cacheKey Cache key.
          * @param terminalId Terminal ID.
-         * @throws IgniteCheckedException If failed.
          */
-        private void put(Object o, String cacheKey, String terminalId) throws IgniteCheckedException {
+        private void put(Object o, String cacheKey, String terminalId) {
 //            GridCache<CacheAffinityKey<String>, Object> cache = ((IgniteKernal)ignite).cache(null);
 //
 //            CacheAffinityKey<String> affinityKey = new CacheAffinityKey<>(cacheKey, terminalId);
@@ -722,10 +720,9 @@ public class GridCacheConcurrentTxMultiNodeTest extends GridCommonAbstractTest {
          * @param cacheKey Cache key.
          * @param terminalId Terminal ID.
          * @return Cached object.
-         * @throws IgniteCheckedException If failed.
          */
         @SuppressWarnings({"RedundantCast"})
-        private <T> Object get(String cacheKey, String terminalId) throws IgniteCheckedException {
+        private <T> Object get(String cacheKey, String terminalId) {
             Object key = new CacheAffinityKey<>(cacheKey, terminalId);
 
             return (T) ignite.jcache(null).get(key);

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCachePutAllFailoverSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCachePutAllFailoverSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCachePutAllFailoverSelfTest.java
index 1fef3c6..9d2fe99 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCachePutAllFailoverSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCachePutAllFailoverSelfTest.java
@@ -558,11 +558,8 @@ public class GridCachePutAllFailoverSelfTest extends GridCommonAbstractTest {
      * @param workerNode Worker node.
      * @param keys Keys that are suspected to be absent
      * @return List of absent keys. If no keys are absent, the list is empty.
-     * @throws IgniteCheckedException If error occurs.
      */
-    private Collection<Integer> findAbsentKeys(Ignite workerNode,
-        Collection<Integer> keys) throws IgniteCheckedException {
-
+    private Collection<Integer> findAbsentKeys(Ignite workerNode, Collection<Integer> keys) {
         Collection<Integer> ret = new ArrayList<>(keys.size());
 
         IgniteCache<Object, Object> cache = workerNode.jcache(CACHE_NAME);

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteTxMultiNodeAbstractTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteTxMultiNodeAbstractTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteTxMultiNodeAbstractTest.java
index e3adab1..d2aaf93 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteTxMultiNodeAbstractTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteTxMultiNodeAbstractTest.java
@@ -153,10 +153,9 @@ public abstract class IgniteTxMultiNodeAbstractTest extends GridCommonAbstractTe
      * @param ignite Grid.
      * @param itemKey Item key.
      * @param retry Retry count.
-     * @throws IgniteCheckedException If failed.
      */
     @SuppressWarnings("unchecked")
-    private void onItemNear(boolean putCntr, Ignite ignite, String itemKey, int retry) throws IgniteCheckedException {
+    private void onItemNear(boolean putCntr, Ignite ignite, String itemKey, int retry) {
         IgniteCache<String, Integer> cache = ignite.jcache(null);
 
         UUID locId = ignite.cluster().localNode().id();
@@ -205,10 +204,9 @@ public abstract class IgniteTxMultiNodeAbstractTest extends GridCommonAbstractTe
      * @param ignite Grid.
      * @param itemKey Item key.
      * @param retry Retry count.
-     * @throws IgniteCheckedException If failed.
      */
     @SuppressWarnings("unchecked")
-    private void onItemPrimary(boolean putCntr, Ignite ignite, String itemKey, int retry) throws IgniteCheckedException {
+    private void onItemPrimary(boolean putCntr, Ignite ignite, String itemKey, int retry) {
         IgniteCache<String, Integer> cache = ignite.jcache(null);
 
         UUID locId = ignite.cluster().localNode().id();
@@ -349,10 +347,9 @@ public abstract class IgniteTxMultiNodeAbstractTest extends GridCommonAbstractTe
      * @param putCntr Put counter to cache.
      * @param ignite Grid.
      * @param retry Retry count.
-     * @throws IgniteCheckedException If failed.
      */
     @SuppressWarnings("unchecked")
-    private void onRemoveItemSimple(boolean putCntr, Ignite ignite, int retry) throws IgniteCheckedException {
+    private void onRemoveItemSimple(boolean putCntr, Ignite ignite, int retry) {
         IgniteCache<String, Integer> cache = ignite.jcache(null);
 
         UUID locId = ignite.cluster().localNode().id();
@@ -417,9 +414,8 @@ public abstract class IgniteTxMultiNodeAbstractTest extends GridCommonAbstractTe
      *
      * @param putCntr Put counter to cache.
      * @param ignite Grid.
-     * @throws IgniteCheckedException If failed.
      */
-    private void retries(Ignite ignite, boolean putCntr) throws IgniteCheckedException {
+    private void retries(Ignite ignite, boolean putCntr) {
         UUID nodeId = ignite.cluster().localNode().id();
 
         for (int i = 0; i < RETRIES; i++) {
@@ -469,9 +465,8 @@ public abstract class IgniteTxMultiNodeAbstractTest extends GridCommonAbstractTe
      *
      * @param putCntr Put counter to cache.
      * @param ignite Grid.
-     * @throws IgniteCheckedException If failed.
      */
-    private void removeRetriesSimple(Ignite ignite, boolean putCntr) throws IgniteCheckedException {
+    private void removeRetriesSimple(Ignite ignite, boolean putCntr) {
         for (int i = 0; i < RETRIES; i++) {
             if (DEBUG)
                 ignite.log().info("***");
@@ -551,12 +546,7 @@ public abstract class IgniteTxMultiNodeAbstractTest extends GridCommonAbstractTe
 
                 threads.add(new Thread("thread-#" + i) {
                     @Override public void run() {
-                        try {
-                            retries(grid(gridId), false);
-                        }
-                        catch (IgniteCheckedException e) {
-                            throw new IgniteException(e);
-                        }
+                        retries(grid(gridId), false);
                     }
                 });
             }
@@ -594,12 +584,7 @@ public abstract class IgniteTxMultiNodeAbstractTest extends GridCommonAbstractTe
 
                 threads.add(new Thread() {
                     @Override public void run() {
-                        try {
-                            retries(grid(gridId), true);
-                        }
-                        catch (IgniteCheckedException e) {
-                            throw new IgniteException(e);
-                        }
+                        retries(grid(gridId), true);
                     }
                 });
             }
@@ -808,9 +793,9 @@ public abstract class IgniteTxMultiNodeAbstractTest extends GridCommonAbstractTe
     }
 
     /**
-     * @throws IgniteCheckedException If failed.
+     *
      */
-    private void printCounter() throws IgniteCheckedException {
+    private void printCounter() {
         info("***");
         info("*** Peeked counter: " + grid(0).jcache(null).localPeek(CNTR_KEY, CachePeekMode.ONHEAP));
         info("*** Got counter: " + grid(0).jcache(null).get(CNTR_KEY));

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheAtomicReferenceMultiNodeAbstractTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheAtomicReferenceMultiNodeAbstractTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheAtomicReferenceMultiNodeAbstractTest.java
index dbdd194..412ad62 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheAtomicReferenceMultiNodeAbstractTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheAtomicReferenceMultiNodeAbstractTest.java
@@ -65,7 +65,7 @@ public abstract class GridCacheAtomicReferenceMultiNodeAbstractTest extends Igni
 
         // Execute task on all grid nodes.
         ignite.compute().call(new IgniteCallable<Object>() {
-            @Override public String call() throws IgniteCheckedException {
+            @Override public String call() {
                 IgniteAtomicReference<String> ref = ignite.atomicReference(refName, val, true);
 
                 assertEquals(val, ref.get());
@@ -78,7 +78,7 @@ public abstract class GridCacheAtomicReferenceMultiNodeAbstractTest extends Igni
 
         // Execute task on all grid nodes.
         ignite.compute().call(new IgniteCallable<String>() {
-            @Override public String call() throws IgniteCheckedException {
+            @Override public String call() {
                 IgniteAtomicReference<String> ref = ignite.atomicReference(refName, val, true);
 
                 assertEquals(val, ref.get());
@@ -91,7 +91,7 @@ public abstract class GridCacheAtomicReferenceMultiNodeAbstractTest extends Igni
 
         // Execute task on all grid nodes.
         ignite.compute().call(new IgniteCallable<String>() {
-            @Override public String call() throws IgniteCheckedException {
+            @Override public String call() {
                 IgniteAtomicReference<String> ref = ignite.atomicReference(refName, val, true);
 
                 assertEquals(newVal, ref.get());
@@ -125,7 +125,7 @@ public abstract class GridCacheAtomicReferenceMultiNodeAbstractTest extends Igni
 
         // Execute task on all grid nodes.
         ignite.compute().call(new IgniteCallable<String>() {
-            @Override public String call() throws IgniteCheckedException {
+            @Override public String call() {
                 IgniteAtomicStamped<String, String> stamped = ignite.atomicStamped(stampedName, val, stamp, true);
 
                 assertEquals(val, stamped.value());
@@ -139,7 +139,7 @@ public abstract class GridCacheAtomicReferenceMultiNodeAbstractTest extends Igni
 
         // Execute task on all grid nodes.
         ignite.compute().call(new IgniteCallable<String>() {
-            @Override public String call() throws IgniteCheckedException {
+            @Override public String call() {
                 IgniteAtomicStamped<String, String> stamped = ignite.atomicStamped(stampedName, val, stamp, true);
 
                 assertEquals(val, stamped.value());
@@ -153,7 +153,7 @@ public abstract class GridCacheAtomicReferenceMultiNodeAbstractTest extends Igni
 
         // Execute task on all grid nodes.
         ignite.compute().call(new IgniteCallable<String>() {
-            @Override public String call() throws IgniteCheckedException {
+            @Override public String call() {
                 IgniteAtomicStamped<String, String> stamped = ignite.atomicStamped(stampedName, val, stamp, true);
 
                 assertEquals(newVal, stamped.value());

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheMultiNodeDataStructureTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheMultiNodeDataStructureTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheMultiNodeDataStructureTest.java
index dd7fa84..2599644 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheMultiNodeDataStructureTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheMultiNodeDataStructureTest.java
@@ -53,9 +53,8 @@ public class GridCacheMultiNodeDataStructureTest {
      *
      * @param g Grid.
      * @param cacheName Cache name.
-     * @throws IgniteCheckedException If failed.
      */
-    private static void sample(Ignite g, String cacheName) throws IgniteCheckedException {
+    private static void sample(Ignite g, String cacheName) {
         IgniteAtomicLong atomicLong = g.atomicLong("keygen", 0, true);
 
         IgniteAtomicSequence seq = g.atomicSequence("keygen", 0, true);

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheSequenceMultiNodeAbstractSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheSequenceMultiNodeAbstractSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheSequenceMultiNodeAbstractSelfTest.java
index fe67880..d6d7c40 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheSequenceMultiNodeAbstractSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheSequenceMultiNodeAbstractSelfTest.java
@@ -126,7 +126,7 @@ public abstract class GridCacheSequenceMultiNodeAbstractSelfTest extends IgniteA
         final IgniteAtomicSequence seq = grid(0).atomicSequence(seqName, 0, true);
 
         grid(1).compute().run(new CAX() {
-            @Override public void applyx() throws IgniteCheckedException {
+            @Override public void applyx() {
                 assertNotNull(seq);
 
                 for (int i = 0; i < RETRIES; i++)

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/partitioned/GridCachePartitionedAtomicSequenceMultiThreadedTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/partitioned/GridCachePartitionedAtomicSequenceMultiThreadedTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/partitioned/GridCachePartitionedAtomicSequenceMultiThreadedTest.java
index fabba18..806dafa 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/partitioned/GridCachePartitionedAtomicSequenceMultiThreadedTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/partitioned/GridCachePartitionedAtomicSequenceMultiThreadedTest.java
@@ -151,7 +151,7 @@ public class GridCachePartitionedAtomicSequenceMultiThreadedTest extends IgniteA
         final IgniteAtomicSequence seq = grid(0).atomicSequence(seqName, 0L, true);
 
         runSequenceClosure(new GridInUnsafeClosure<IgniteAtomicSequence>() {
-            @Override public void apply(IgniteAtomicSequence t) throws IgniteCheckedException {
+            @Override public void apply(IgniteAtomicSequence t) {
                 t.incrementAndGet();
             }
         }, seq, ITERATION_NUM, THREAD_NUM);
@@ -167,7 +167,7 @@ public class GridCachePartitionedAtomicSequenceMultiThreadedTest extends IgniteA
         final IgniteAtomicSequence seq = grid(0).atomicSequence(seqName, 0L, true);
 
         runSequenceClosure(new GridInUnsafeClosure<IgniteAtomicSequence>() {
-            @Override public void apply(IgniteAtomicSequence t) throws IgniteCheckedException {
+            @Override public void apply(IgniteAtomicSequence t) {
                 t.incrementAndGet();
             }
         }, seq, ITERATION_NUM, THREAD_NUM);
@@ -183,7 +183,7 @@ public class GridCachePartitionedAtomicSequenceMultiThreadedTest extends IgniteA
         final IgniteAtomicSequence seq = grid(0).atomicSequence(seqName, 0L, true);
 
         runSequenceClosure(new GridInUnsafeClosure<IgniteAtomicSequence>() {
-            @Override public void apply(IgniteAtomicSequence t) throws IgniteCheckedException {
+            @Override public void apply(IgniteAtomicSequence t) {
                 t.getAndIncrement();
             }
         }, seq, ITERATION_NUM, THREAD_NUM);
@@ -199,7 +199,7 @@ public class GridCachePartitionedAtomicSequenceMultiThreadedTest extends IgniteA
         final IgniteAtomicSequence seq = grid(0).atomicSequence(seqName, 0L, true);
 
         runSequenceClosure(new GridInUnsafeClosure<IgniteAtomicSequence>() {
-            @Override public void apply(IgniteAtomicSequence t) throws IgniteCheckedException {
+            @Override public void apply(IgniteAtomicSequence t) {
                 t.getAndIncrement();
             }
         }, seq, ITERATION_NUM, THREAD_NUM);
@@ -215,7 +215,7 @@ public class GridCachePartitionedAtomicSequenceMultiThreadedTest extends IgniteA
         final IgniteAtomicSequence seq = grid(0).atomicSequence(seqName, 0L, true);
 
         runSequenceClosure(new GridInUnsafeClosure<IgniteAtomicSequence>() {
-            @Override public void apply(IgniteAtomicSequence t) throws IgniteCheckedException {
+            @Override public void apply(IgniteAtomicSequence t) {
                 t.addAndGet(5);
             }
         }, seq, ITERATION_NUM, THREAD_NUM);
@@ -231,7 +231,7 @@ public class GridCachePartitionedAtomicSequenceMultiThreadedTest extends IgniteA
         final IgniteAtomicSequence seq = grid(0).atomicSequence(seqName, 0L, true);
 
         runSequenceClosure(new GridInUnsafeClosure<IgniteAtomicSequence>() {
-            @Override public void apply(IgniteAtomicSequence t) throws IgniteCheckedException {
+            @Override public void apply(IgniteAtomicSequence t) {
                 t.getAndAdd(5);
             }
         }, seq, ITERATION_NUM, THREAD_NUM);
@@ -247,7 +247,7 @@ public class GridCachePartitionedAtomicSequenceMultiThreadedTest extends IgniteA
         final IgniteAtomicSequence seq = grid(0).atomicSequence(seqName, 0L, true);
 
         runSequenceClosure(new GridInUnsafeClosure<IgniteAtomicSequence>() {
-            @Override public void apply(IgniteAtomicSequence t) throws IgniteCheckedException {
+            @Override public void apply(IgniteAtomicSequence t) {
                 t.incrementAndGet();
                 t.getAndIncrement();
                 t.incrementAndGet();
@@ -268,7 +268,7 @@ public class GridCachePartitionedAtomicSequenceMultiThreadedTest extends IgniteA
         final IgniteAtomicSequence seq = grid(0).atomicSequence(seqName, 0L, true);
 
         runSequenceClosure(new GridInUnsafeClosure<IgniteAtomicSequence>() {
-            @Override public void apply(IgniteAtomicSequence t) throws IgniteCheckedException {
+            @Override public void apply(IgniteAtomicSequence t) {
                 t.getAndAdd(2);
                 t.addAndGet(3);
                 t.addAndGet(5);

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/partitioned/GridCachePartitionedQueueEntryMoveSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/partitioned/GridCachePartitionedQueueEntryMoveSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/partitioned/GridCachePartitionedQueueEntryMoveSelfTest.java
index e6039a8..4791191 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/partitioned/GridCachePartitionedQueueEntryMoveSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/partitioned/GridCachePartitionedQueueEntryMoveSelfTest.java
@@ -104,7 +104,7 @@ public class GridCachePartitionedQueueEntryMoveSelfTest extends IgniteCollection
             //final CountDownLatch latch2 = new CountDownLatch(1);
 
             IgniteInternalFuture<?> fut1 = GridTestUtils.runAsync(new Callable<Void>() {
-                @Override public Void call() throws IgniteCheckedException {
+                @Override public Void call() {
                     Ignite ignite = grid(0);
 
                     IgniteQueue<Integer> queue = ignite.queue(queueName,

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheAbstractJobExecutionTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheAbstractJobExecutionTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheAbstractJobExecutionTest.java
index d52b67e..fadf54b 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheAbstractJobExecutionTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheAbstractJobExecutionTest.java
@@ -128,7 +128,7 @@ public abstract class GridCacheAbstractJobExecutionTest extends GridCommonAbstra
                 @IgniteInstanceResource
                 private Ignite ignite;
 
-                @Override public Void applyx(final Integer i) throws IgniteCheckedException {
+                @Override public Void applyx(final Integer i) {
                     IgniteCache<String, int[]> cache = ignite.jcache(null);
 
                     try (Transaction tx = ignite.transactions().txStart(concur, isolation)) {

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheEventAbstractTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheEventAbstractTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheEventAbstractTest.java
index def2f09..24cd202 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheEventAbstractTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheEventAbstractTest.java
@@ -135,10 +135,8 @@ public abstract class GridCacheEventAbstractTest extends GridCacheAbstractSelfTe
 
     /**
      * Clear caches without generating events.
-     *
-     * @throws IgniteCheckedException If failed to clear caches.
      */
-    private void clearCaches() throws IgniteCheckedException {
+    private void clearCaches() {
         for (int i = 0; i < gridCnt; i++) {
             IgniteCache<String, Integer> cache = jcache(i);
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridCacheDhtInternalEntrySelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridCacheDhtInternalEntrySelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridCacheDhtInternalEntrySelfTest.java
index f88c080..cc274ce 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridCacheDhtInternalEntrySelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridCacheDhtInternalEntrySelfTest.java
@@ -149,18 +149,16 @@ public class GridCacheDhtInternalEntrySelfTest extends GridCommonAbstractTest {
     /**
      * @param node Node.
      * @return Atomic long value.
-     * @throws IgniteCheckedException In case of error.
      */
-    private Object peekNear(ClusterNode node) throws IgniteCheckedException {
+    private Object peekNear(ClusterNode node) {
         return grid(node).jcache(null).localPeek(new GridCacheInternalKeyImpl(ATOMIC_LONG_NAME), CachePeekMode.NEAR);
     }
 
     /**
      * @param node Node.
      * @return Atomic long value.
-     * @throws IgniteCheckedException In case of error.
      */
-    private Object peekDht(ClusterNode node) throws IgniteCheckedException {
+    private Object peekDht(ClusterNode node) {
         return grid(node).jcache(null).localPeek(new GridCacheInternalKeyImpl(ATOMIC_LONG_NAME), CachePeekMode.BACKUP,
             CachePeekMode.PRIMARY);
     }

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridCacheDhtMultiBackupTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridCacheDhtMultiBackupTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridCacheDhtMultiBackupTest.java
index ebbd71d..e40b670 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridCacheDhtMultiBackupTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridCacheDhtMultiBackupTest.java
@@ -51,7 +51,7 @@ public class GridCacheDhtMultiBackupTest extends GridCommonAbstractTest {
                     @IgniteInstanceResource
                     private Ignite g;
 
-                    @Override public void applyx() throws IgniteCheckedException {
+                    @Override public void applyx() {
                         X.println("Checking whether cache is empty.");
 
                         IgniteCache<SampleKey, SampleValue> cache = g.jcache("partitioned");

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedHitsAndMissesSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedHitsAndMissesSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedHitsAndMissesSelfTest.java
index d3464ea..8950f45 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedHitsAndMissesSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedHitsAndMissesSelfTest.java
@@ -138,9 +138,8 @@ public class GridCachePartitionedHitsAndMissesSelfTest extends GridCommonAbstrac
      * Populates cache with data loader.
      *
      * @param g Grid.
-     * @throws IgniteCheckedException If failed.
      */
-    private static void realTimePopulate(final Ignite g) throws IgniteCheckedException {
+    private static void realTimePopulate(final Ignite g) {
         try (IgniteDataLoader<Integer, Long> ldr = g.dataLoader(null)) {
             // Sets max values to 1 so cache metrics have correct values.
             ldr.perNodeParallelLoadOperations(1);

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedMultiThreadedPutGetSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedMultiThreadedPutGetSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedMultiThreadedPutGetSelfTest.java
index 32eff24..c4430dd 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedMultiThreadedPutGetSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCachePartitionedMultiThreadedPutGetSelfTest.java
@@ -177,7 +177,7 @@ public class GridCachePartitionedMultiThreadedPutGetSelfTest extends GridCommonA
 
         multithreaded(new CAX() {
             @SuppressWarnings({"BusyWait"})
-            @Override public void applyx() throws IgniteCheckedException {
+            @Override public void applyx() {
                 IgniteCache<Integer, Integer> c = grid(0).jcache(null);
 
                 for (int i = 0; i < TX_CNT; i++) {

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/eviction/random/GridCacheRandomEvictionPolicySelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/eviction/random/GridCacheRandomEvictionPolicySelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/eviction/random/GridCacheRandomEvictionPolicySelfTest.java
index d77158a..d14e1a0 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/eviction/random/GridCacheRandomEvictionPolicySelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/eviction/random/GridCacheRandomEvictionPolicySelfTest.java
@@ -176,7 +176,7 @@ public class GridCacheRandomEvictionPolicySelfTest extends
                 t[i] = Integer.toString(i);
 
             multithreaded(new Callable() {
-                @Nullable @Override public Object call() throws IgniteCheckedException {
+                @Nullable @Override public Object call() {
                     int runs = 3000;
 
                     for (int i = 0; i < runs; i++) {

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7423b7cb/modules/core/src/test/java/org/apache/ignite/internal/processors/closure/GridClosureProcessorSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/closure/GridClosureProcessorSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/closure/GridClosureProcessorSelfTest.java
index fb5f8dc..0b178ff 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/closure/GridClosureProcessorSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/closure/GridClosureProcessorSelfTest.java
@@ -187,10 +187,8 @@ public class GridClosureProcessorSelfTest extends GridCommonAbstractTest {
      * @param job Runnable job.
      * @param p Optional node predicate.
      * @return Future object.
-     * @throws IgniteCheckedException If failed.
      */
-    private ComputeTaskFuture<?> runAsync(int idx, IgniteRunnable job, @Nullable IgnitePredicate<ClusterNode> p)
-        throws IgniteCheckedException {
+    private ComputeTaskFuture<?> runAsync(int idx, IgniteRunnable job, @Nullable IgnitePredicate<ClusterNode> p) {
         assert idx >= 0 && idx < NODES_CNT;
         assert job != null;
 
@@ -210,10 +208,8 @@ public class GridClosureProcessorSelfTest extends GridCommonAbstractTest {
      * @param job Runnable job.
      * @param p Optional node predicate.
      * @return Future object.
-     * @throws IgniteCheckedException If failed.
      */
-    private ComputeTaskFuture<?> broadcast(int idx, IgniteRunnable job, @Nullable IgnitePredicate<ClusterNode> p)
-        throws IgniteCheckedException {
+    private ComputeTaskFuture<?> broadcast(int idx, IgniteRunnable job, @Nullable IgnitePredicate<ClusterNode> p) {
         assert idx >= 0 && idx < NODES_CNT;
         assert job != null;
 
@@ -283,10 +279,9 @@ public class GridClosureProcessorSelfTest extends GridCommonAbstractTest {
      * @param job Callable job.
      * @param p Optional node predicate.
      * @return Future object.
-     * @throws IgniteCheckedException If failed.
      */
     private ComputeTaskFuture<Collection<Integer>> broadcast(int idx, IgniteCallable<Integer> job,
-        @Nullable IgnitePredicate<ClusterNode> p) throws IgniteCheckedException {
+        @Nullable IgnitePredicate<ClusterNode> p) {
         assert idx >= 0 && idx < NODES_CNT;
         assert job != null;
 
@@ -306,10 +301,9 @@ public class GridClosureProcessorSelfTest extends GridCommonAbstractTest {
      * @param jobs Callable job.
      * @param p Optional node predicate.
      * @return Future object.
-     * @throws IgniteCheckedException If failed.
      */
     private ComputeTaskFuture<Collection<Integer>> callAsync(int idx, Collection<TestCallable> jobs,
-        @Nullable IgnitePredicate<ClusterNode> p) throws IgniteCheckedException {
+        @Nullable IgnitePredicate<ClusterNode> p) {
         assert idx >= 0 && idx < NODES_CNT;
         assert !F.isEmpty(jobs);
 


Mime
View raw message