ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From yzhda...@apache.org
Subject [12/32] ignite git commit: IGNITE-4612 Minor code cleanup
Date Mon, 06 Feb 2017 10:11:25 GMT
http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/core/src/test/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerTimeoutTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerTimeoutTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerTimeoutTest.java
index 766aa84..410f196 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerTimeoutTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerTimeoutTest.java
@@ -94,7 +94,7 @@ public class DataStreamerTimeoutTest extends GridCommonAbstractTest {
             for (int i = 0; i < ENTRY_AMOUNT; i++)
                 ldr.addData(i, i);
         }
-        catch (CacheException | IgniteDataStreamerTimeoutException e) {
+        catch (CacheException | IgniteDataStreamerTimeoutException ignored) {
             thrown = true;
         }
         finally {
@@ -153,11 +153,11 @@ public class DataStreamerTimeoutTest extends GridCommonAbstractTest {
                         processed++;
                     }
                 }
-                catch (IllegalStateException e) {
+                catch (IllegalStateException ignored) {
                     // No-op.
                 }
             }
-            catch (CacheException | IgniteDataStreamerTimeoutException e) {
+            catch (CacheException | IgniteDataStreamerTimeoutException ignored) {
                 thrown = true;
             }
         }

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsAbstractSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsAbstractSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsAbstractSelfTest.java
index 128239d..c2d76df 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
@@ -487,10 +487,10 @@ public abstract class IgfsAbstractSelfTest extends IgfsAbstractBaseSelfTest {
         catch (IgfsParentNotDirectoryException ignore) {
             // No-op.
         }
-        catch (IgfsException ignore) {
+        catch (IgfsException e) {
             // Currently Ok for Hadoop fs:
             if (!getClass().getSimpleName().startsWith("Hadoop"))
-                throw ignore;
+                throw e;
         }
 
         try {
@@ -501,10 +501,10 @@ public abstract class IgfsAbstractSelfTest extends IgfsAbstractBaseSelfTest {
         catch (IgfsParentNotDirectoryException ignore) {
             // No-op.
         }
-        catch (IgfsException ignore) {
+        catch (IgfsException e) {
             // Currently Ok for Hadoop fs:
             if (!getClass().getSimpleName().startsWith("Hadoop"))
-                throw ignore;
+                throw e;
         }
 
         create(igfs, paths(DIR, SUBDIR), null);
@@ -942,8 +942,8 @@ public abstract class IgfsAbstractSelfTest extends IgfsAbstractBaseSelfTest {
             try (IgfsOutputStream os = igfs.create(new IgfsPath("/k/l"), false)) {}
 
             fail("Exception expected");
-        } catch (IgniteException e) {
-            // okay
+        } catch (IgniteException ignored) {
+            // No-op.
         }
 
         checkExist(igfs, igfsSecondary, new IgfsPath("/k/l"));
@@ -953,7 +953,7 @@ public abstract class IgfsAbstractSelfTest extends IgfsAbstractBaseSelfTest {
             try (IgfsOutputStream os = igfs.create(new IgfsPath("/k/l/m"), true)) {}
 
             fail("Exception expected");
-        } catch (IgniteException e) {
+        } catch (IgniteException ignored) {
             // okay
         }
         checkNotExist(igfs, igfsSecondary, new IgfsPath("/k/l/m"));
@@ -964,7 +964,7 @@ public abstract class IgfsAbstractSelfTest extends IgfsAbstractBaseSelfTest {
             try (IgfsOutputStream os = igfs.create(new IgfsPath("/k/l/m/n/o/p"), true)) {}
 
             fail("Exception expected");
-        } catch (IgniteException e) {
+        } catch (IgniteException ignored) {
             // okay
         }
         checkNotExist(igfs, igfsSecondary, new IgfsPath("/k/l/m"));
@@ -976,7 +976,7 @@ public abstract class IgfsAbstractSelfTest extends IgfsAbstractBaseSelfTest {
             try (IgfsOutputStream os = igfs.create(new IgfsPath("/x/y"), true)) {}
 
             fail("Exception expected");
-        } catch (IgniteException e) {
+        } catch (IgniteException ignored) {
             // okay
         }
 
@@ -1337,7 +1337,7 @@ public abstract class IgfsAbstractSelfTest extends IgfsAbstractBaseSelfTest {
 
                         createCtr.incrementAndGet();
                     }
-                    catch (IgniteException e) {
+                    catch (IgniteException ignored) {
                         // No-op.
                     }
                     catch (IOException e) {
@@ -1439,7 +1439,7 @@ public abstract class IgfsAbstractSelfTest extends IgfsAbstractBaseSelfTest {
                 }
 
                 fail("Exception expected");
-            } catch (IgniteException e) {
+            } catch (IgniteException ignored) {
                 // okay
             }
             checkNotExist(igfs, igfsSecondary, new IgfsPath("/d1"));
@@ -1457,7 +1457,7 @@ public abstract class IgfsAbstractSelfTest extends IgfsAbstractBaseSelfTest {
                 }
 
                 fail("Exception expected");
-            } catch (IgniteException e) {
+            } catch (IgniteException ignored) {
                 // okay
             }
             checkNotExist(igfs, igfsSecondary, new IgfsPath("/k/l/m"));
@@ -1471,7 +1471,7 @@ public abstract class IgfsAbstractSelfTest extends IgfsAbstractBaseSelfTest {
                 }
 
                 fail("Exception expected");
-            } catch (IgniteException e) {
+            } catch (IgniteException ignored) {
                 // okay
             }
             checkNotExist(igfs, igfsSecondary, new IgfsPath("/k/l/m"));
@@ -1488,7 +1488,7 @@ public abstract class IgfsAbstractSelfTest extends IgfsAbstractBaseSelfTest {
                 }
 
                 fail("Exception expected");
-            } catch (IgniteException e) {
+            } catch (IgniteException ignored) {
                 // okay
             }
 
@@ -1519,7 +1519,7 @@ public abstract class IgfsAbstractSelfTest extends IgfsAbstractBaseSelfTest {
                 }
 
                 fail("Exception expected");
-            } catch (IgniteException e) {
+            } catch (IgniteException ignored) {
                 // okay
             }
             checkNotExist(igfs, igfsSecondary, new IgfsPath("/d1"));
@@ -2549,4 +2549,4 @@ public abstract class IgfsAbstractSelfTest extends IgfsAbstractBaseSelfTest {
 
         U.joinThreads(threads, null);
     }
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsFileInfoSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsFileInfoSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsFileInfoSelfTest.java
index 486179c..b2b87dc 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsFileInfoSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsFileInfoSelfTest.java
@@ -43,8 +43,6 @@ public class IgfsFileInfoSelfTest extends IgfsCommonAbstractTest {
     public void testSerialization() throws Exception {
         marshaller.setContext(new MarshallerContextTestImpl());
 
-        final int max = Integer.MAX_VALUE;
-
         multithreaded(new Callable<Object>() {
             private final Random rnd = new Random();
 
@@ -77,4 +75,4 @@ public class IgfsFileInfoSelfTest extends IgfsCommonAbstractTest {
     private <T> T mu(T obj) throws IgniteCheckedException {
         return marshaller.unmarshal(marshaller.marshal(obj), null);
     }
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsMetaManagerSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsMetaManagerSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsMetaManagerSelfTest.java
index a4100ea..01e1a2e 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsMetaManagerSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsMetaManagerSelfTest.java
@@ -158,7 +158,6 @@ public class IgfsMetaManagerSelfTest extends IgfsCommonAbstractTest {
 
         for (IgniteBiTuple<IgniteUuid, String> tup: Arrays.asList(F.t(dir.id(), "dir"), F.t(file.id(), "file"))) {
             IgniteUuid fileId = tup.get1();
-            String fileName = tup.get2();
 
             for (Map<String, String> props : Arrays.asList(null, Collections.<String, String>emptyMap()))
                 expectsUpdatePropertiesFail(fileId, props, AssertionError.class, "Expects not-empty file's properties");
@@ -419,4 +418,4 @@ public class IgfsMetaManagerSelfTest extends IgfsCommonAbstractTest {
 
         assertTrue("Unexpected cause: " + err, err instanceof IgfsException);
     }
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsModeResolverSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsModeResolverSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsModeResolverSelfTest.java
index 7932660..2b231cd 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsModeResolverSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsModeResolverSelfTest.java
@@ -98,8 +98,8 @@ public class IgfsModeResolverSelfTest extends TestCase {
 
             fail("IgniteCheckedException expected");
         }
-        catch (IgniteCheckedException ice) {
-            // Expected.
+        catch (IgniteCheckedException ignored) {
+            // No-op.
         }
 
         // PRIMARY default mode and non-primary subfolder:
@@ -111,8 +111,8 @@ public class IgfsModeResolverSelfTest extends TestCase {
 
                     fail("IgniteCheckedException expected");
                 }
-                catch (IgniteCheckedException ice) {
-                    // Expected.
+                catch (IgniteCheckedException ignored) {
+                    // No-op.
                 }
             }
         }
@@ -178,4 +178,4 @@ public class IgfsModeResolverSelfTest extends TestCase {
             add(new IgfsPath("/a/b/x/y"));
         }});
     }
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/benchmark/IgfsBenchmark.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/benchmark/IgfsBenchmark.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/benchmark/IgfsBenchmark.java
index 9cf6e8f..f3bce8e 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/benchmark/IgfsBenchmark.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/benchmark/IgfsBenchmark.java
@@ -96,7 +96,7 @@ class WriteFileOperation extends FileOperation {
     /** {@inheritDoc} */
     @Override public void handleFile(String strPath) throws Exception {
         IgfsPath path = new IgfsPath(strPath);
-        IgfsOutputStream out = null;
+        IgfsOutputStream out;
 
         try {
             out = fs.create(path, false);
@@ -154,7 +154,7 @@ class ReadFileOperation extends FileOperation {
     /** {@inheritDoc} */
     @Override public void handleFile(String strPath) throws Exception {
         IgfsPath path = new IgfsPath(strPath);
-        IgfsInputStream in = null;
+        IgfsInputStream in;
 
         try {
             in = fs.open(path);

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/core/src/test/java/org/apache/ignite/internal/processors/rest/handlers/cache/GridCacheCommandHandlerSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/rest/handlers/cache/GridCacheCommandHandlerSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/rest/handlers/cache/GridCacheCommandHandlerSelfTest.java
index eadf674..c26376e 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/rest/handlers/cache/GridCacheCommandHandlerSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/rest/handlers/cache/GridCacheCommandHandlerSelfTest.java
@@ -38,7 +38,6 @@ import org.apache.ignite.internal.IgniteInternalFuture;
 import org.apache.ignite.internal.IgniteKernal;
 import org.apache.ignite.internal.processors.cache.IgniteInternalCache;
 import org.apache.ignite.internal.processors.rest.GridRestCommand;
-import org.apache.ignite.internal.processors.rest.GridRestResponse;
 import org.apache.ignite.internal.processors.rest.handlers.GridRestCommandHandler;
 import org.apache.ignite.internal.processors.rest.request.GridRestCacheRequest;
 import org.apache.ignite.internal.util.future.GridFinishedFuture;

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/core/src/test/java/org/apache/ignite/internal/processors/service/GridServiceDeploymentExceptionPropagationTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/service/GridServiceDeploymentExceptionPropagationTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/service/GridServiceDeploymentExceptionPropagationTest.java
index 811594f..156a72e 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/service/GridServiceDeploymentExceptionPropagationTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/service/GridServiceDeploymentExceptionPropagationTest.java
@@ -45,7 +45,7 @@ public class GridServiceDeploymentExceptionPropagationTest extends GridCommonAbs
                 try {
                     client.services().deployClusterSingleton("my-service", new ServiceImpl());
                 }
-                catch (IgniteException e) {
+                catch (IgniteException ignored) {
                     assertTrue(log.toString().contains("ServiceImpl init exception"));
 
                     return; // Exception is what we expect.

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/core/src/test/java/org/apache/ignite/internal/processors/service/GridServiceProcessorStopSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/service/GridServiceProcessorStopSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/service/GridServiceProcessorStopSelfTest.java
index 92b18ab..08595f7 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/service/GridServiceProcessorStopSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/service/GridServiceProcessorStopSelfTest.java
@@ -65,7 +65,7 @@ public class GridServiceProcessorStopSelfTest extends GridCommonAbstractTest {
                 try {
                     services.future().get();
                 }
-                catch (IgniteException e) {
+                catch (IgniteException ignored) {
                     finishLatch.countDown();
                 }
                 finally {

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/core/src/test/java/org/apache/ignite/internal/processors/service/IgniteServiceReassignmentTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/service/IgniteServiceReassignmentTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/service/IgniteServiceReassignmentTest.java
index d7937ec..09c631c 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/service/IgniteServiceReassignmentTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/service/IgniteServiceReassignmentTest.java
@@ -176,7 +176,7 @@ public class IgniteServiceReassignmentTest extends GridCommonAbstractTest {
 
                     return true;
                 }
-                catch (IgniteException e) {
+                catch (IgniteException ignored) {
                     return false;
                 }
             }

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/core/src/test/java/org/apache/ignite/internal/util/IgniteUtilsSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/util/IgniteUtilsSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/util/IgniteUtilsSelfTest.java
index d774065..c068984 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/util/IgniteUtilsSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/util/IgniteUtilsSelfTest.java
@@ -54,7 +54,6 @@ import org.apache.ignite.lang.IgniteBiTuple;
 import org.apache.ignite.lang.IgnitePredicate;
 import org.apache.ignite.testframework.GridTestUtils;
 import org.apache.ignite.testframework.http.GridEmbeddedHttpServer;
-import org.apache.ignite.testframework.junits.GridTestKernalContext;
 import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest;
 import org.apache.ignite.testframework.junits.common.GridCommonTest;
 import org.jetbrains.annotations.Nullable;
@@ -325,7 +324,7 @@ public class IgniteUtilsSelfTest extends GridCommonAbstractTest {
 
             col = Arrays.asList(this, this, this);
 
-            GridTestKernalContext ctx = newContext();
+            newContext();
 
             subGrid = ignite.cluster().forNodes(Collections.singleton(node));
         }
@@ -780,4 +779,4 @@ public class IgniteUtilsSelfTest extends GridCommonAbstractTest {
     private interface I3 extends I2 {}
     @Ann2 private interface I4 {}
     private interface I5 extends I4 {}
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/core/src/test/java/org/apache/ignite/internal/util/offheap/unsafe/GridOffheapSnapTreeSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/util/offheap/unsafe/GridOffheapSnapTreeSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/util/offheap/unsafe/GridOffheapSnapTreeSelfTest.java
index 92d9ec2..0d97d54 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/util/offheap/unsafe/GridOffheapSnapTreeSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/util/offheap/unsafe/GridOffheapSnapTreeSelfTest.java
@@ -72,7 +72,10 @@ public class GridOffheapSnapTreeSelfTest extends GridCommonAbstractTest {
                         guard.begin();
 
                         try {
-                            GridOffHeapSmartPointer res = put ? m.put(fx, fx) : m.remove(fx);
+                            if (put)
+                                m.put(fx, fx);
+                            else
+                                m.remove(fx);
                         }
                         finally {
                             lock.readLock().unlock();
@@ -320,4 +323,4 @@ public class GridOffheapSnapTreeSelfTest extends GridCommonAbstractTest {
             return ptr + "(" + refs + ")";
         }
     }
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/core/src/test/java/org/apache/ignite/lang/GridMetadataAwareAdapterSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/lang/GridMetadataAwareAdapterSelfTest.java b/modules/core/src/test/java/org/apache/ignite/lang/GridMetadataAwareAdapterSelfTest.java
index a0a926a..f202fa9 100644
--- a/modules/core/src/test/java/org/apache/ignite/lang/GridMetadataAwareAdapterSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/lang/GridMetadataAwareAdapterSelfTest.java
@@ -51,7 +51,7 @@ public class GridMetadataAwareAdapterSelfTest extends GridCommonAbstractTest {
         int k3 = cnt++;
         int a1 = cnt++;
         int a2 = cnt++;
-        int a3 = cnt++;
+        int a3 = cnt;
 
         // addMeta(name, val).
         assert ma.addMeta(attr1, "val1") == null;
@@ -139,4 +139,4 @@ public class GridMetadataAwareAdapterSelfTest extends GridCommonAbstractTest {
 
         assert !ma.hasMeta(a3);
     }
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/core/src/test/java/org/apache/ignite/p2p/GridP2PSameClassLoaderSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/p2p/GridP2PSameClassLoaderSelfTest.java b/modules/core/src/test/java/org/apache/ignite/p2p/GridP2PSameClassLoaderSelfTest.java
index ba5e15b..9ac4852 100644
--- a/modules/core/src/test/java/org/apache/ignite/p2p/GridP2PSameClassLoaderSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/p2p/GridP2PSameClassLoaderSelfTest.java
@@ -82,12 +82,10 @@ public class GridP2PSameClassLoaderSelfTest extends GridCommonAbstractTest {
 
     /**
      * Test.
-     * @param isIsolatedDifferentTask Isolated different task flag.
-     * @param isIsolatedDifferentNode Isolated different mode flag.
      * @throws Exception if error occur
      */
     @SuppressWarnings({"unchecked"})
-    private void processTest(boolean isIsolatedDifferentTask, boolean isIsolatedDifferentNode) throws Exception {
+    private void processTest() throws Exception {
         try {
             final Ignite ignite1 = startGrid(1);
             Ignite ignite2 = startGrid(2);
@@ -128,7 +126,7 @@ public class GridP2PSameClassLoaderSelfTest extends GridCommonAbstractTest {
     public void testPrivateMode() throws Exception {
         depMode = DeploymentMode.PRIVATE;
 
-        processTest(true, true);
+        processTest();
     }
 
     /**
@@ -139,7 +137,7 @@ public class GridP2PSameClassLoaderSelfTest extends GridCommonAbstractTest {
     public void testIsolatedMode() throws Exception {
         depMode = DeploymentMode.ISOLATED;
 
-        processTest(false, true);
+        processTest();
     }
 
     /**
@@ -150,7 +148,7 @@ public class GridP2PSameClassLoaderSelfTest extends GridCommonAbstractTest {
     public void testContinuousMode() throws Exception {
         depMode = DeploymentMode.CONTINUOUS;
 
-        processTest(false, false);
+        processTest();
     }
 
     /**
@@ -161,7 +159,7 @@ public class GridP2PSameClassLoaderSelfTest extends GridCommonAbstractTest {
     public void testSharedMode() throws Exception {
         depMode = DeploymentMode.SHARED;
 
-        processTest(false, false);
+        processTest();
     }
 
     /**
@@ -177,4 +175,4 @@ public class GridP2PSameClassLoaderSelfTest extends GridCommonAbstractTest {
 
         return m1[0] != m2[0] && m1[1] != m2[1];
     }
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/core/src/test/java/org/apache/ignite/platform/PlatformEventsWriteEventTask.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/platform/PlatformEventsWriteEventTask.java b/modules/core/src/test/java/org/apache/ignite/platform/PlatformEventsWriteEventTask.java
index 9fbe272..2e5a3e8 100644
--- a/modules/core/src/test/java/org/apache/ignite/platform/PlatformEventsWriteEventTask.java
+++ b/modules/core/src/test/java/org/apache/ignite/platform/PlatformEventsWriteEventTask.java
@@ -23,15 +23,6 @@ import org.apache.ignite.compute.ComputeJob;
 import org.apache.ignite.compute.ComputeJobAdapter;
 import org.apache.ignite.compute.ComputeJobResult;
 import org.apache.ignite.compute.ComputeTaskAdapter;
-import org.apache.ignite.events.CacheEvent;
-import org.apache.ignite.events.CacheQueryExecutedEvent;
-import org.apache.ignite.events.CacheQueryReadEvent;
-import org.apache.ignite.events.CacheRebalancingEvent;
-import org.apache.ignite.events.CheckpointEvent;
-import org.apache.ignite.events.DiscoveryEvent;
-import org.apache.ignite.events.JobEvent;
-import org.apache.ignite.events.SwapSpaceEvent;
-import org.apache.ignite.events.TaskEvent;
 import org.apache.ignite.internal.binary.BinaryRawWriterEx;
 import org.apache.ignite.internal.processors.platform.PlatformContext;
 import org.apache.ignite.internal.processors.platform.memory.PlatformMemory;

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/core/src/test/java/org/apache/ignite/spi/deployment/local/GridLocalDeploymentSpiSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/spi/deployment/local/GridLocalDeploymentSpiSelfTest.java b/modules/core/src/test/java/org/apache/ignite/spi/deployment/local/GridLocalDeploymentSpiSelfTest.java
index 9a1c9a0..1483364 100644
--- a/modules/core/src/test/java/org/apache/ignite/spi/deployment/local/GridLocalDeploymentSpiSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/spi/deployment/local/GridLocalDeploymentSpiSelfTest.java
@@ -128,7 +128,7 @@ public class GridLocalDeploymentSpiSelfTest extends GridSpiAbstractTest<LocalDep
 
             assert false : "Exception must be thrown for registering with the same name.";
         }
-        catch (IgniteSpiException e) {
+        catch (IgniteSpiException ignored) {
             // No-op.
         }
 
@@ -147,7 +147,7 @@ public class GridLocalDeploymentSpiSelfTest extends GridSpiAbstractTest<LocalDep
 
             assert false : "Exception must be thrown for registering with the same name.";
         }
-        catch (IgniteSpiException e) {
+        catch (IgniteSpiException ignored) {
             // No-op.
         }
 
@@ -192,4 +192,4 @@ public class GridLocalDeploymentSpiSelfTest extends GridSpiAbstractTest<LocalDep
             return null;
         }
     }
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpiFailureTimeoutSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpiFailureTimeoutSelfTest.java b/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpiFailureTimeoutSelfTest.java
index 35aa934..a0545f5 100644
--- a/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpiFailureTimeoutSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpiFailureTimeoutSelfTest.java
@@ -313,8 +313,8 @@ public class TcpClientDiscoverySpiFailureTimeoutSelfTest extends TcpClientDiscov
                     try {
                         Thread.sleep(2000);
                     }
-                    catch (InterruptedException e) {
-                        // Ignore
+                    catch (InterruptedException ignored) {
+                        // No-op.
                     }
 
                     throw new SocketTimeoutException("Forced timeout");

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySelfTest.java b/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySelfTest.java
index 043208c..fc40f13 100644
--- a/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySelfTest.java
@@ -1327,7 +1327,7 @@ public class TcpDiscoverySelfTest extends GridCommonAbstractTest {
 
                 nodeSpi.set(new TestCustomEventRaceSpi());
 
-                Ignite ignite2 = startGrid(2);
+                startGrid(2);
 
                 return null;
             }
@@ -2040,7 +2040,7 @@ public class TcpDiscoverySelfTest extends GridCommonAbstractTest {
 
                     return false;
                 }
-                catch (IgniteIllegalStateException e) {
+                catch (IgniteIllegalStateException ignored) {
                     return true;
                 }
             }
@@ -2406,8 +2406,8 @@ public class TcpDiscoverySelfTest extends GridCommonAbstractTest {
                     try {
                         Thread.sleep(5_000);
                     }
-                    catch (InterruptedException e) {
-                        // Ignore.
+                    catch (InterruptedException ignored) {
+                        // No-op.
                     }
                 }
 

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpiFailureTimeoutSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpiFailureTimeoutSelfTest.java b/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpiFailureTimeoutSelfTest.java
index 4ef984f..a496f30 100644
--- a/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpiFailureTimeoutSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpiFailureTimeoutSelfTest.java
@@ -323,14 +323,14 @@ public class TcpDiscoverySpiFailureTimeoutSelfTest extends AbstractDiscoverySelf
                 try {
                     Thread.sleep(timeout + 1000);
                 }
-                catch (InterruptedException e) {
-                    // Ignore
+                catch (InterruptedException ignored) {
+                    // No-op.
                 }
 
                 try {
                     timeoutHelper.nextTimeoutChunk(0);
                 }
-                catch (IgniteSpiOperationTimeoutException e) {
+                catch (IgniteSpiOperationTimeoutException ignored) {
                     throw (err = new IgniteSpiOperationTimeoutException("Timeout: openSocketTimeoutWait"));
                 }
             }
@@ -340,8 +340,8 @@ public class TcpDiscoverySpiFailureTimeoutSelfTest extends AbstractDiscoverySelf
             try {
                 Thread.sleep(1500);
             }
-            catch (InterruptedException e) {
-                // Ignore
+            catch (InterruptedException ignored) {
+                // No-op.
             }
 
             return sock;
@@ -369,8 +369,8 @@ public class TcpDiscoverySpiFailureTimeoutSelfTest extends AbstractDiscoverySelf
                 try {
                     Thread.sleep(timeout);
                 }
-                catch (InterruptedException e) {
-                    // Ignore
+                catch (InterruptedException ignored) {
+                    // No-op.
                 }
             }
             else

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/core/src/test/java/org/apache/ignite/spi/swapspace/GridSwapSpaceSpiAbstractSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/spi/swapspace/GridSwapSpaceSpiAbstractSelfTest.java b/modules/core/src/test/java/org/apache/ignite/spi/swapspace/GridSwapSpaceSpiAbstractSelfTest.java
index 9e927dd..e573afc 100644
--- a/modules/core/src/test/java/org/apache/ignite/spi/swapspace/GridSwapSpaceSpiAbstractSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/spi/swapspace/GridSwapSpaceSpiAbstractSelfTest.java
@@ -30,7 +30,6 @@ import org.apache.ignite.internal.util.typedef.CI1;
 import org.apache.ignite.internal.util.typedef.F;
 import org.apache.ignite.internal.util.typedef.P1;
 import org.apache.ignite.internal.util.typedef.internal.S;
-import org.apache.ignite.internal.util.typedef.internal.U;
 import org.apache.ignite.lang.IgniteInClosure;
 import org.apache.ignite.spi.IgniteSpiCloseableIterator;
 import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest;
@@ -650,4 +649,4 @@ public abstract class GridSwapSpaceSpiAbstractSelfTest extends GridCommonAbstrac
             return "Key: " + i;
         }
     }
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/core/src/test/java/org/apache/ignite/testframework/GridSpiTestContext.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/testframework/GridSpiTestContext.java b/modules/core/src/test/java/org/apache/ignite/testframework/GridSpiTestContext.java
index ac50ef9..b19d07b 100644
--- a/modules/core/src/test/java/org/apache/ignite/testframework/GridSpiTestContext.java
+++ b/modules/core/src/test/java/org/apache/ignite/testframework/GridSpiTestContext.java
@@ -665,10 +665,9 @@ public class GridSpiTestContext implements IgniteSpiContext {
         @Override public void onMessage(UUID nodeId, Object msg) {
             GridIoUserMessage ioMsg = (GridIoUserMessage)msg;
 
-            ClusterNode node = locNode;
-                Object msgBody = ioMsg.body();
+            Object msgBody = ioMsg.body();
 
-                assert msgBody != null || ioMsg.bodyBytes() != null;
+            assert msgBody != null || ioMsg.bodyBytes() != null;
         }
 
         /** {@inheritDoc} */

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/core/src/test/java/org/apache/ignite/testframework/IgniteTestSuite.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/testframework/IgniteTestSuite.java b/modules/core/src/test/java/org/apache/ignite/testframework/IgniteTestSuite.java
index 157e1f5..861c139 100644
--- a/modules/core/src/test/java/org/apache/ignite/testframework/IgniteTestSuite.java
+++ b/modules/core/src/test/java/org/apache/ignite/testframework/IgniteTestSuite.java
@@ -130,7 +130,7 @@ public class IgniteTestSuite extends TestSuite {
         try {
             getTestConstructor(theClass);
         }
-        catch (NoSuchMethodException ex) {
+        catch (NoSuchMethodException ignored) {
             addTest(warning("Class " + theClass.getName() +
                 " has no public constructor TestCase(String name) or TestCase()"));
 

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteCacheDataStructuresSelfTestSuite.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteCacheDataStructuresSelfTestSuite.java b/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteCacheDataStructuresSelfTestSuite.java
index d14aa4e..980d550 100644
--- a/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteCacheDataStructuresSelfTestSuite.java
+++ b/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteCacheDataStructuresSelfTestSuite.java
@@ -24,7 +24,6 @@ import org.apache.ignite.internal.processors.cache.datastructures.IgniteClientDa
 import org.apache.ignite.internal.processors.cache.datastructures.IgniteClientDiscoveryDataStructuresTest;
 import org.apache.ignite.internal.processors.cache.datastructures.IgniteDataStructureUniqueNameTest;
 import org.apache.ignite.internal.processors.cache.datastructures.IgniteDataStructureWithJobTest;
-import org.apache.ignite.internal.processors.cache.datastructures.SemaphoreFailoverSafeReleasePermitsTest;
 import org.apache.ignite.internal.processors.cache.datastructures.local.GridCacheLocalAtomicOffheapSetSelfTest;
 import org.apache.ignite.internal.processors.cache.datastructures.local.GridCacheLocalAtomicQueueApiSelfTest;
 import org.apache.ignite.internal.processors.cache.datastructures.local.GridCacheLocalAtomicSetSelfTest;
@@ -69,7 +68,6 @@ import org.apache.ignite.internal.processors.cache.datastructures.partitioned.Gr
 import org.apache.ignite.internal.processors.cache.datastructures.partitioned.GridCachePartitionedSetSelfTest;
 import org.apache.ignite.internal.processors.cache.datastructures.partitioned.IgnitePartitionedAtomicLongApiSelfTest;
 import org.apache.ignite.internal.processors.cache.datastructures.partitioned.IgnitePartitionedCountDownLatchSelfTest;
-import org.apache.ignite.internal.processors.cache.datastructures.partitioned.IgnitePartitionedLockSelfTest;
 import org.apache.ignite.internal.processors.cache.datastructures.partitioned.IgnitePartitionedQueueNoBackupsTest;
 import org.apache.ignite.internal.processors.cache.datastructures.partitioned.IgnitePartitionedSemaphoreSelfTest;
 import org.apache.ignite.internal.processors.cache.datastructures.partitioned.IgnitePartitionedSetNoBackupsSelfTest;

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteMessagingConfigVariationFullApiTestSuite.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteMessagingConfigVariationFullApiTestSuite.java b/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteMessagingConfigVariationFullApiTestSuite.java
index 6933ae9..bfb9cd1 100644
--- a/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteMessagingConfigVariationFullApiTestSuite.java
+++ b/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteMessagingConfigVariationFullApiTestSuite.java
@@ -27,8 +27,6 @@ import org.apache.ignite.testframework.configvariations.ConfigVariations;
 import org.apache.ignite.testframework.configvariations.ConfigVariationsTestSuiteBuilder;
 import org.apache.ignite.testframework.configvariations.Parameters;
 
-import javax.cache.configuration.Factory;
-
 /**
  * Test sute for Messaging process.
  */
@@ -69,4 +67,4 @@ public class IgniteMessagingConfigVariationFullApiTestSuite extends TestSuite {
 
         return suite;
     }
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/core/src/test/java/org/apache/ignite/util/mbeans/GridMBeanSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/util/mbeans/GridMBeanSelfTest.java b/modules/core/src/test/java/org/apache/ignite/util/mbeans/GridMBeanSelfTest.java
index 58be549..4f5ed19 100644
--- a/modules/core/src/test/java/org/apache/ignite/util/mbeans/GridMBeanSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/util/mbeans/GridMBeanSelfTest.java
@@ -90,7 +90,7 @@ public class GridMBeanSelfTest extends GridCommonAbstractTest {
 
             mbean.getMBeanInfo();
         }
-        catch (AssertionError e) {
+        catch (AssertionError ignored) {
             return;
         }
 
@@ -109,7 +109,7 @@ public class GridMBeanSelfTest extends GridCommonAbstractTest {
 
             mbean.getMBeanInfo();
         }
-        catch (AssertionError e) {
+        catch (AssertionError ignored) {
             return;
         }
 
@@ -128,7 +128,7 @@ public class GridMBeanSelfTest extends GridCommonAbstractTest {
 
             mbean.getMBeanInfo();
         }
-        catch (AssertionError e) {
+        catch (AssertionError ignored) {
             return;
         }
 
@@ -147,7 +147,7 @@ public class GridMBeanSelfTest extends GridCommonAbstractTest {
 
             mbean.getMBeanInfo();
         }
-        catch (AssertionError e) {
+        catch (AssertionError ignored) {
             return;
         }
 
@@ -371,4 +371,4 @@ public class GridMBeanSelfTest extends GridCommonAbstractTest {
             return null;
         }
     }
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/extdata/p2p/src/main/java/org/apache/ignite/tests/p2p/cache/CacheNoValueClassOnServerTestClient.java
----------------------------------------------------------------------
diff --git a/modules/extdata/p2p/src/main/java/org/apache/ignite/tests/p2p/cache/CacheNoValueClassOnServerTestClient.java b/modules/extdata/p2p/src/main/java/org/apache/ignite/tests/p2p/cache/CacheNoValueClassOnServerTestClient.java
index 5c82469..bbf8abf 100644
--- a/modules/extdata/p2p/src/main/java/org/apache/ignite/tests/p2p/cache/CacheNoValueClassOnServerTestClient.java
+++ b/modules/extdata/p2p/src/main/java/org/apache/ignite/tests/p2p/cache/CacheNoValueClassOnServerTestClient.java
@@ -22,7 +22,6 @@ import org.apache.ignite.Ignite;
 import org.apache.ignite.IgniteCache;
 import org.apache.ignite.Ignition;
 import org.apache.ignite.configuration.IgniteConfiguration;
-import org.apache.ignite.internal.util.typedef.internal.U;
 import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi;
 import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder;
 
@@ -84,4 +83,4 @@ public class CacheNoValueClassOnServerTestClient {
             }
         }
     }
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/extdata/p2p/src/main/java/org/apache/ignite/tests/p2p/startcache/CacheConfigurationP2PTestClient.java
----------------------------------------------------------------------
diff --git a/modules/extdata/p2p/src/main/java/org/apache/ignite/tests/p2p/startcache/CacheConfigurationP2PTestClient.java b/modules/extdata/p2p/src/main/java/org/apache/ignite/tests/p2p/startcache/CacheConfigurationP2PTestClient.java
index e0406c2..9798025 100644
--- a/modules/extdata/p2p/src/main/java/org/apache/ignite/tests/p2p/startcache/CacheConfigurationP2PTestClient.java
+++ b/modules/extdata/p2p/src/main/java/org/apache/ignite/tests/p2p/startcache/CacheConfigurationP2PTestClient.java
@@ -24,7 +24,6 @@ import org.apache.ignite.Ignition;
 import org.apache.ignite.cache.query.SqlQuery;
 import org.apache.ignite.configuration.CacheConfiguration;
 import org.apache.ignite.configuration.IgniteConfiguration;
-import org.apache.ignite.internal.util.typedef.internal.U;
 import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi;
 import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder;
 
@@ -114,4 +113,4 @@ public class CacheConfigurationP2PTestClient {
             cache2.destroy();
         }
     }
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/gce/src/main/java/org/apache/ignite/spi/discovery/tcp/ipfinder/gce/TcpDiscoveryGoogleStorageIpFinder.java
----------------------------------------------------------------------
diff --git a/modules/gce/src/main/java/org/apache/ignite/spi/discovery/tcp/ipfinder/gce/TcpDiscoveryGoogleStorageIpFinder.java b/modules/gce/src/main/java/org/apache/ignite/spi/discovery/tcp/ipfinder/gce/TcpDiscoveryGoogleStorageIpFinder.java
index 980c696..71074c0 100644
--- a/modules/gce/src/main/java/org/apache/ignite/spi/discovery/tcp/ipfinder/gce/TcpDiscoveryGoogleStorageIpFinder.java
+++ b/modules/gce/src/main/java/org/apache/ignite/spi/discovery/tcp/ipfinder/gce/TcpDiscoveryGoogleStorageIpFinder.java
@@ -379,7 +379,7 @@ public class TcpDiscoveryGoogleStorageIpFinder extends TcpDiscoveryIpFinderAdapt
         try {
             port = Integer.parseInt(res[1]);
         }
-        catch (NumberFormatException e) {
+        catch (NumberFormatException ignored) {
             throw new IgniteSpiException("Invalid port number: " + res[1]);
         }
 
@@ -403,4 +403,4 @@ public class TcpDiscoveryGoogleStorageIpFinder extends TcpDiscoveryIpFinderAdapt
             throw new IgniteSpiException("Failed to remove the bucket: " + bucketName, e);
         }
     }
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/igfs/HadoopIgfsEndpoint.java
----------------------------------------------------------------------
diff --git a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/igfs/HadoopIgfsEndpoint.java b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/igfs/HadoopIgfsEndpoint.java
index a44e1ae..23db921 100644
--- a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/igfs/HadoopIgfsEndpoint.java
+++ b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/igfs/HadoopIgfsEndpoint.java
@@ -158,7 +158,7 @@ public class HadoopIgfsEndpoint {
                 if (port < 0 || port > 65535)
                     throw new IgniteCheckedException("Invalid port number: " + connStr);
             }
-            catch (NumberFormatException e) {
+            catch (NumberFormatException ignored) {
                 throw new IgniteCheckedException("Invalid port number: " + connStr);
             }
         }
@@ -207,4 +207,4 @@ public class HadoopIgfsEndpoint {
     @Override public String toString() {
         return S.toString(HadoopIgfsEndpoint.class, this);
     }
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/impl/delegate/HadoopBasicFileSystemFactoryDelegate.java
----------------------------------------------------------------------
diff --git a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/impl/delegate/HadoopBasicFileSystemFactoryDelegate.java b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/impl/delegate/HadoopBasicFileSystemFactoryDelegate.java
index 59488be..2db0271 100644
--- a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/impl/delegate/HadoopBasicFileSystemFactoryDelegate.java
+++ b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/impl/delegate/HadoopBasicFileSystemFactoryDelegate.java
@@ -154,7 +154,7 @@ public class HadoopBasicFileSystemFactoryDelegate implements HadoopFileSystemFac
             try {
                 fullUri = new URI(proxy0.getUri());
             }
-            catch (URISyntaxException use) {
+            catch (URISyntaxException ignored) {
                 throw new IgniteException("Failed to resolve secondary file system URI: " + proxy0.getUri());
             }
         }

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/impl/igfs/HadoopIgfsInProc.java
----------------------------------------------------------------------
diff --git a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/impl/igfs/HadoopIgfsInProc.java b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/impl/igfs/HadoopIgfsInProc.java
index 8bdcc83..f9f98ed 100644
--- a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/impl/igfs/HadoopIgfsInProc.java
+++ b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/impl/igfs/HadoopIgfsInProc.java
@@ -117,7 +117,7 @@ public class HadoopIgfsInProc implements HadoopIgfsEx {
         catch (IgniteException e) {
             throw new IgniteCheckedException(e);
         }
-        catch (IllegalStateException e) {
+        catch (IllegalStateException ignored) {
             throw new HadoopIgfsCommunicationException("Failed to get file info because Grid is stopping: " + path);
         }
     }
@@ -134,7 +134,7 @@ public class HadoopIgfsInProc implements HadoopIgfsEx {
         catch (IgniteException e) {
             throw new IgniteCheckedException(e);
         }
-        catch (IllegalStateException e) {
+        catch (IllegalStateException ignored) {
             throw new HadoopIgfsCommunicationException("Failed to update file because Grid is stopping: " + path);
         }
     }
@@ -155,9 +155,8 @@ public class HadoopIgfsInProc implements HadoopIgfsEx {
         catch (IgniteException e) {
             throw new IgniteCheckedException(e);
         }
-        catch (IllegalStateException e) {
-            throw new HadoopIgfsCommunicationException("Failed to set path times because Grid is stopping: " +
-                path);
+        catch (IllegalStateException ignored) {
+            throw new HadoopIgfsCommunicationException("Failed to set path times because Grid is stopping: " + path);
         }
     }
 
@@ -177,7 +176,7 @@ public class HadoopIgfsInProc implements HadoopIgfsEx {
         catch (IgniteException e) {
             throw new IgniteCheckedException(e);
         }
-        catch (IllegalStateException e) {
+        catch (IllegalStateException ignored) {
             throw new HadoopIgfsCommunicationException("Failed to rename path because Grid is stopping: " + src);
         }
     }
@@ -194,7 +193,7 @@ public class HadoopIgfsInProc implements HadoopIgfsEx {
         catch (IgniteException e) {
             throw new IgniteCheckedException(e);
         }
-        catch (IllegalStateException e) {
+        catch (IllegalStateException ignored) {
             throw new HadoopIgfsCommunicationException("Failed to delete path because Grid is stopping: " + path);
         }
     }
@@ -208,14 +207,13 @@ public class HadoopIgfsInProc implements HadoopIgfsEx {
                 }
             });
         }
-        catch (IllegalStateException e) {
-            throw new HadoopIgfsCommunicationException("Failed to get file system status because Grid is " +
-                "stopping.");
+        catch (IllegalStateException ignored) {
+            throw new HadoopIgfsCommunicationException("Failed to get file system status because Grid is stopping.");
         }
         catch (IgniteCheckedException | RuntimeException | Error e) {
             throw e;
         }
-        catch (Exception e) {
+        catch (Exception ignored) {
             throw new AssertionError("Must never go there.");
         }
     }
@@ -232,7 +230,7 @@ public class HadoopIgfsInProc implements HadoopIgfsEx {
         catch (IgniteException e) {
             throw new IgniteCheckedException(e);
         }
-        catch (IllegalStateException e) {
+        catch (IllegalStateException ignored) {
             throw new HadoopIgfsCommunicationException("Failed to list paths because Grid is stopping: " + path);
         }
     }
@@ -249,7 +247,7 @@ public class HadoopIgfsInProc implements HadoopIgfsEx {
         catch (IgniteException e) {
             throw new IgniteCheckedException(e);
         }
-        catch (IllegalStateException e) {
+        catch (IllegalStateException ignored) {
             throw new HadoopIgfsCommunicationException("Failed to list files because Grid is stopping: " + path);
         }
     }
@@ -270,7 +268,7 @@ public class HadoopIgfsInProc implements HadoopIgfsEx {
         catch (IgniteException e) {
             throw new IgniteCheckedException(e);
         }
-        catch (IllegalStateException e) {
+        catch (IllegalStateException ignored) {
             throw new HadoopIgfsCommunicationException("Failed to create directory because Grid is stopping: " +
                 path);
         }
@@ -288,7 +286,7 @@ public class HadoopIgfsInProc implements HadoopIgfsEx {
         catch (IgniteException e) {
             throw new IgniteCheckedException(e);
         }
-        catch (IllegalStateException e) {
+        catch (IllegalStateException ignored) {
             throw new HadoopIgfsCommunicationException("Failed to get content summary because Grid is stopping: " +
                 path);
         }
@@ -307,7 +305,7 @@ public class HadoopIgfsInProc implements HadoopIgfsEx {
         catch (IgniteException e) {
             throw new IgniteCheckedException(e);
         }
-        catch (IllegalStateException e) {
+        catch (IllegalStateException ignored) {
             throw new HadoopIgfsCommunicationException("Failed to get affinity because Grid is stopping: " + path);
         }
     }
@@ -326,7 +324,7 @@ public class HadoopIgfsInProc implements HadoopIgfsEx {
         catch (IgniteException e) {
             throw new IgniteCheckedException(e);
         }
-        catch (IllegalStateException e) {
+        catch (IllegalStateException ignored) {
             throw new HadoopIgfsCommunicationException("Failed to open file because Grid is stopping: " + path);
         }
     }
@@ -346,7 +344,7 @@ public class HadoopIgfsInProc implements HadoopIgfsEx {
         catch (IgniteException e) {
             throw new IgniteCheckedException(e);
         }
-        catch (IllegalStateException e) {
+        catch (IllegalStateException ignored) {
             throw new HadoopIgfsCommunicationException("Failed to open file because Grid is stopping: " + path);
         }
     }
@@ -367,7 +365,7 @@ public class HadoopIgfsInProc implements HadoopIgfsEx {
         catch (IgniteException e) {
             throw new IgniteCheckedException(e);
         }
-        catch (IllegalStateException e) {
+        catch (IllegalStateException ignored) {
             throw new HadoopIgfsCommunicationException("Failed to create file because Grid is stopping: " + path);
         }
     }
@@ -387,7 +385,7 @@ public class HadoopIgfsInProc implements HadoopIgfsEx {
         catch (IgniteException e) {
             throw new IgniteCheckedException(e);
         }
-        catch (IllegalStateException e) {
+        catch (IllegalStateException ignored) {
             throw new HadoopIgfsCommunicationException("Failed to append file because Grid is stopping: " + path);
         }
     }
@@ -508,4 +506,4 @@ public class HadoopIgfsInProc implements HadoopIgfsEx {
     @Override public String user() {
         return user;
     }
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/impl/v2/HadoopV2Context.java
----------------------------------------------------------------------
diff --git a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/impl/v2/HadoopV2Context.java b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/impl/v2/HadoopV2Context.java
index 1f4e675..6202622 100644
--- a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/impl/v2/HadoopV2Context.java
+++ b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/impl/v2/HadoopV2Context.java
@@ -31,7 +31,6 @@ import org.apache.hadoop.mapreduce.task.JobContextImpl;
 import org.apache.ignite.IgniteCheckedException;
 import org.apache.ignite.internal.processors.hadoop.HadoopFileBlock;
 import org.apache.ignite.internal.processors.hadoop.HadoopInputSplit;
-import org.apache.ignite.internal.processors.hadoop.HadoopMapperAwareTaskOutput;
 import org.apache.ignite.internal.processors.hadoop.HadoopTaskCancelledException;
 import org.apache.ignite.internal.processors.hadoop.HadoopTaskContext;
 import org.apache.ignite.internal.processors.hadoop.HadoopTaskInput;
@@ -242,4 +241,4 @@ public class HadoopV2Context extends JobContextImpl implements MapContext, Reduc
     public void cancel() {
         cancelled = true;
     }
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/taskexecutor/HadoopExecutorService.java
----------------------------------------------------------------------
diff --git a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/taskexecutor/HadoopExecutorService.java b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/taskexecutor/HadoopExecutorService.java
index 993ecc9..a5f3df9 100644
--- a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/taskexecutor/HadoopExecutorService.java
+++ b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/taskexecutor/HadoopExecutorService.java
@@ -130,7 +130,7 @@ public class HadoopExecutorService {
                     return; // Rejected due to shutdown.
             }
         }
-        catch (InterruptedException e) {
+        catch (InterruptedException ignored) {
             Thread.currentThread().interrupt();
 
             return;
@@ -217,7 +217,7 @@ public class HadoopExecutorService {
 
                 awaitTimeMillis -= 100;
             }
-            catch (InterruptedException e) {
+            catch (InterruptedException ignored) {
                 break;
             }
         }
@@ -231,4 +231,4 @@ public class HadoopExecutorService {
     public boolean isShutdown() {
         return shutdown;
     }
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/taskexecutor/external/child/HadoopChildProcessRunner.java
----------------------------------------------------------------------
diff --git a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/taskexecutor/external/child/HadoopChildProcessRunner.java b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/taskexecutor/external/child/HadoopChildProcessRunner.java
index 3336120..0f418e7 100644
--- a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/taskexecutor/external/child/HadoopChildProcessRunner.java
+++ b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/taskexecutor/external/child/HadoopChildProcessRunner.java
@@ -153,7 +153,7 @@ public class HadoopChildProcessRunner {
                 shuffleJob = new HadoopShuffleJob<>(comm.localProcessDescriptor(), log, job, mem,
                     req.totalReducerCount(), req.localReducers(), 0, false);
 
-                initializeExecutors(req);
+                initializeExecutors();
 
                 if (log.isDebugEnabled())
                     log.debug("External process initialized [initWaitTime=" +
@@ -233,13 +233,9 @@ public class HadoopChildProcessRunner {
     /**
      * Creates executor services.
      *
-     * @param req Init child process request.
      */
-    private void initializeExecutors(HadoopPrepareForJobRequest req) {
+    private void initializeExecutors() {
         int cpus = Runtime.getRuntime().availableProcessors();
-//
-//        concMappers = get(req.jobInfo(), EXTERNAL_CONCURRENT_MAPPERS, cpus);
-//        concReducers = get(req.jobInfo(), EXTERNAL_CONCURRENT_REDUCERS, cpus);
 
         execSvc = new HadoopExecutorService(log, "", cpus * 2, 1024);
     }
@@ -466,4 +462,4 @@ public class HadoopChildProcessRunner {
             }
         }
     }
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/impl/HadoopErrorSimulator.java
----------------------------------------------------------------------
diff --git a/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/impl/HadoopErrorSimulator.java b/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/impl/HadoopErrorSimulator.java
index b89dcc1..7c76cc3 100644
--- a/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/impl/HadoopErrorSimulator.java
+++ b/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/impl/HadoopErrorSimulator.java
@@ -208,8 +208,8 @@ public class HadoopErrorSimulator {
                 if ((bits & 1) != 0)
                     simulateError();
             }
-            catch (IOException e) {
-                // ignore
+            catch (IOException ignored) {
+                // No-op.
             }
         }
 
@@ -237,8 +237,8 @@ public class HadoopErrorSimulator {
                 if ((bits & 16) != 0)
                     simulateError();
             }
-            catch (IOException e) {
-                // ignore
+            catch (IOException ignored) {
+                // No-op.
             }
         }
 
@@ -266,8 +266,8 @@ public class HadoopErrorSimulator {
                 if ((bits & 256) != 0)
                     simulateError();
             }
-            catch (IOException e) {
-                // ignore
+            catch (IOException ignored) {
+                // No-op.
             }
         }
 

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/impl/igfs/HadoopIgfs20FileSystemAbstractSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/impl/igfs/HadoopIgfs20FileSystemAbstractSelfTest.java b/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/impl/igfs/HadoopIgfs20FileSystemAbstractSelfTest.java
index d8f6f54..a297aef 100644
--- a/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/impl/igfs/HadoopIgfs20FileSystemAbstractSelfTest.java
+++ b/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/impl/igfs/HadoopIgfs20FileSystemAbstractSelfTest.java
@@ -66,7 +66,6 @@ import org.apache.ignite.igfs.IgfsIpcEndpointConfiguration;
 import org.apache.ignite.igfs.IgfsMetrics;
 import org.apache.ignite.igfs.IgfsMode;
 import org.apache.ignite.igfs.IgfsPath;
-import org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsUtils;
 import org.apache.ignite.internal.processors.igfs.IgfsCommonAbstractTest;
 import org.apache.ignite.internal.util.GridConcurrentHashSet;
 import org.apache.ignite.internal.util.typedef.F;
@@ -2044,4 +2043,4 @@ public abstract class HadoopIgfs20FileSystemAbstractSelfTest extends IgfsCommonA
                 pathUri.getAuthority() != null ? secondaryUri.getAuthority() : null, pathUri.getPath(), null, null));
         }
     }
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/impl/igfs/IgniteHadoopFileSystemClientSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/impl/igfs/IgniteHadoopFileSystemClientSelfTest.java b/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/impl/igfs/IgniteHadoopFileSystemClientSelfTest.java
index 555da1e..ed806db 100644
--- a/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/impl/igfs/IgniteHadoopFileSystemClientSelfTest.java
+++ b/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/impl/igfs/IgniteHadoopFileSystemClientSelfTest.java
@@ -33,10 +33,6 @@ import org.apache.ignite.igfs.IgfsIpcEndpointType;
 import org.apache.ignite.igfs.IgfsPath;
 import org.apache.ignite.internal.IgniteKernal;
 import org.apache.ignite.internal.igfs.common.IgfsLogger;
-import org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfs;
-import org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsOutProc;
-import org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsOutputStream;
-import org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsStreamDelegate;
 import org.apache.ignite.internal.processors.igfs.IgfsCommonAbstractTest;
 import org.apache.ignite.internal.processors.igfs.IgfsContext;
 import org.apache.ignite.internal.processors.igfs.IgfsProcessorAdapter;
@@ -213,4 +209,4 @@ public class IgniteHadoopFileSystemClientSelfTest extends IgfsCommonAbstractTest
 
         return (T)field.get(obj);
     }
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/GridH2ResultSetIterator.java
----------------------------------------------------------------------
diff --git a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/GridH2ResultSetIterator.java b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/GridH2ResultSetIterator.java
index c8c26c4..fed292a 100644
--- a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/GridH2ResultSetIterator.java
+++ b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/GridH2ResultSetIterator.java
@@ -22,7 +22,6 @@ import java.sql.ResultSet;
 import java.sql.SQLException;
 import java.util.NoSuchElementException;
 import org.apache.ignite.IgniteCheckedException;
-import org.apache.ignite.IgniteException;
 import org.apache.ignite.internal.processors.cache.GridCacheContext;
 import org.apache.ignite.internal.processors.query.IgniteSQLException;
 import org.apache.ignite.internal.processors.query.h2.opt.GridH2ValueCacheObject;
@@ -189,4 +188,4 @@ public abstract class GridH2ResultSetIterator<T> extends GridCloseableIteratorAd
     @Override public String toString() {
         return S.toString(GridH2ResultSetIterator.class, this);
     }
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/IgniteH2Indexing.java
----------------------------------------------------------------------
diff --git a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/IgniteH2Indexing.java b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/IgniteH2Indexing.java
index 9037943..cf044e2 100644
--- a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/IgniteH2Indexing.java
+++ b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/IgniteH2Indexing.java
@@ -1232,7 +1232,7 @@ public class IgniteH2Indexing implements GridQueryIndexing {
                             try {
                                 ctx.cache().createMissingCaches();
                             }
-                            catch (IgniteCheckedException e1) {
+                            catch (IgniteCheckedException ignored) {
                                 throw new CacheException("Failed to create missing caches.", e);
                             }
 
@@ -3151,4 +3151,4 @@ public class IgniteH2Indexing implements GridQueryIndexing {
         for (Connection conn : conns)
             U.close(conn, log);
     }
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/opt/GridH2IndexBase.java
----------------------------------------------------------------------
diff --git a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/opt/GridH2IndexBase.java b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/opt/GridH2IndexBase.java
index c29239f..3820cdc 100644
--- a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/opt/GridH2IndexBase.java
+++ b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/opt/GridH2IndexBase.java
@@ -1228,7 +1228,7 @@ public abstract class GridH2IndexBase extends BaseIndex {
                 try {
                     res = respQueue.poll(500, TimeUnit.MILLISECONDS);
                 }
-                catch (InterruptedException e) {
+                catch (InterruptedException ignored) {
                     throw new GridH2RetryException("Interrupted.");
                 }
 
@@ -1535,4 +1535,4 @@ public abstract class GridH2IndexBase extends BaseIndex {
             return fltr.apply(key, val);
         }
     }
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/sql/DmlAstUtils.java
----------------------------------------------------------------------
diff --git a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/sql/DmlAstUtils.java b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/sql/DmlAstUtils.java
index 6deb146..9752c5f 100644
--- a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/sql/DmlAstUtils.java
+++ b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/sql/DmlAstUtils.java
@@ -382,7 +382,7 @@ public final class DmlAstUtils {
         try {
             dfltVal = dfltExpr != null ? dfltExpr.getValue(null) : null;
         }
-        catch (Exception e) {
+        catch (Exception ignored) {
             throw new IgniteSQLException("Failed to evaluate default value for a column " + col.columnName());
         }
 

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/msg/GridH2Geometry.java
----------------------------------------------------------------------
diff --git a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/msg/GridH2Geometry.java b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/msg/GridH2Geometry.java
index 0d118b4..88aba55 100644
--- a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/msg/GridH2Geometry.java
+++ b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/msg/GridH2Geometry.java
@@ -41,7 +41,7 @@ public class GridH2Geometry extends GridH2ValueMessage {
         try {
             GEOMETRY_FROM_BYTES = Class.forName("org.h2.value.ValueGeometry").getMethod("get", byte[].class);
         }
-        catch (NoSuchMethodException | ClassNotFoundException e) {
+        catch (NoSuchMethodException | ClassNotFoundException ignored) {
             throw new IllegalStateException("Check H2 version in classpath.");
         }
     }

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/BinarySerializationQuerySelfTest.java
----------------------------------------------------------------------
diff --git a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/BinarySerializationQuerySelfTest.java b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/BinarySerializationQuerySelfTest.java
index 669c482..d205065 100644
--- a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/BinarySerializationQuerySelfTest.java
+++ b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/BinarySerializationQuerySelfTest.java
@@ -31,7 +31,6 @@ import org.apache.ignite.cache.CacheMode;
 import org.apache.ignite.cache.CacheRebalanceMode;
 import org.apache.ignite.cache.CacheTypeMetadata;
 import org.apache.ignite.cache.CacheWriteSynchronizationMode;
-import org.apache.ignite.cache.query.QueryCursor;
 import org.apache.ignite.cache.query.SqlFieldsQuery;
 import org.apache.ignite.cache.query.SqlQuery;
 import org.apache.ignite.configuration.BinaryConfiguration;
@@ -56,7 +55,6 @@ import java.util.ArrayList;
 import java.util.Collections;
 import java.util.Iterator;
 import java.util.List;
-import java.util.Map;
 
 /**
  * Test for query with BinaryMarshaller and different serialization modes.

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/CacheRandomOperationsMultithreadedTest.java
----------------------------------------------------------------------
diff --git a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/CacheRandomOperationsMultithreadedTest.java b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/CacheRandomOperationsMultithreadedTest.java
index dc0175d..c1e94f0 100644
--- a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/CacheRandomOperationsMultithreadedTest.java
+++ b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/CacheRandomOperationsMultithreadedTest.java
@@ -227,7 +227,7 @@ public class CacheRandomOperationsMultithreadedTest extends GridCommonAbstractTe
                     ThreadLocalRandom rnd = ThreadLocalRandom.current();
 
                     while (U.currentTimeMillis() < stopTime)
-                        randomOperation(rnd, ignite, cache, indexing);
+                        randomOperation(rnd, cache, indexing);
                 }
             }, 1, "test-thread");
         }
@@ -238,12 +238,10 @@ public class CacheRandomOperationsMultithreadedTest extends GridCommonAbstractTe
 
     /**
      * @param rnd Random generator.
-     * @param ignite Node.
      * @param cache Cache.
      * @param indexing Indexing flag.
      */
     private void randomOperation(ThreadLocalRandom rnd,
-        Ignite ignite,
         IgniteCache<Object, Object> cache,
         boolean indexing) {
         int r0 = rnd.nextInt(100);

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/ClientReconnectAfterClusterRestartTest.java
----------------------------------------------------------------------
diff --git a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/ClientReconnectAfterClusterRestartTest.java b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/ClientReconnectAfterClusterRestartTest.java
index b31447c..ec94b0c 100644
--- a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/ClientReconnectAfterClusterRestartTest.java
+++ b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/ClientReconnectAfterClusterRestartTest.java
@@ -113,7 +113,7 @@ public class ClientReconnectAfterClusterRestartTest extends GridCommonAbstractTe
     /** */
     public void testReconnectClient() throws Exception {
         try {
-            Ignite igniteSrv = startGrid(0);
+            startGrid(0);
 
             Ignite client = startGrid(1);
 
@@ -159,7 +159,7 @@ public class ClientReconnectAfterClusterRestartTest extends GridCommonAbstractTe
 
             Thread.sleep(2_000);
 
-            igniteSrv = startGrid(0);
+            startGrid(0);
 
             Thread.sleep(2_000);
 

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheQueryIndexDisabledSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheQueryIndexDisabledSelfTest.java b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheQueryIndexDisabledSelfTest.java
index b3aedfc..3b1cf11 100644
--- a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheQueryIndexDisabledSelfTest.java
+++ b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheQueryIndexDisabledSelfTest.java
@@ -80,7 +80,7 @@ public class GridCacheQueryIndexDisabledSelfTest extends GridCommonAbstractTest
         catch (CacheException e) {
             X.println("Caught expected exception: " + e);
         }
-        catch (Exception e) {
+        catch (Exception ignored) {
             assert false;
         }
     }
@@ -99,7 +99,7 @@ public class GridCacheQueryIndexDisabledSelfTest extends GridCommonAbstractTest
         catch (CacheException e) {
             X.println("Caught expected exception: " + e);
         }
-        catch (Exception e) {
+        catch (Exception ignored) {
             assert false;
         }
 
@@ -111,7 +111,7 @@ public class GridCacheQueryIndexDisabledSelfTest extends GridCommonAbstractTest
         catch (CacheException e) {
             X.println("Caught expected exception: " + e);
         }
-        catch (Exception e) {
+        catch (Exception ignored) {
             assert false;
         }
     }
@@ -130,7 +130,7 @@ public class GridCacheQueryIndexDisabledSelfTest extends GridCommonAbstractTest
         catch (CacheException e) {
             X.println("Caught expected exception: " + e);
         }
-        catch (Exception e) {
+        catch (Exception ignored) {
             assert false;
         }
     }
@@ -148,7 +148,7 @@ public class GridCacheQueryIndexDisabledSelfTest extends GridCommonAbstractTest
                 }
             }).setLocal(true)).getAll();
         }
-        catch (IgniteException e) {
+        catch (IgniteException ignored) {
             assertTrue("Scan query should work with disable query indexing.", false);
         }
     }
@@ -166,7 +166,7 @@ public class GridCacheQueryIndexDisabledSelfTest extends GridCommonAbstractTest
         catch (CacheException e) {
             X.println("Caught expected exception: " + e);
         }
-        catch (Exception e) {
+        catch (Exception ignored) {
             assert false;
         }
     }
@@ -185,7 +185,7 @@ public class GridCacheQueryIndexDisabledSelfTest extends GridCommonAbstractTest
         catch (CacheException e) {
             X.println("Caught expected exception: " + e);
         }
-        catch (Exception e) {
+        catch (Exception ignored) {
             assert false;
         }
     }
@@ -204,7 +204,7 @@ public class GridCacheQueryIndexDisabledSelfTest extends GridCommonAbstractTest
         catch (CacheException e) {
             X.println("Caught expected exception: " + e);
         }
-        catch (Exception e) {
+        catch (Exception ignored) {
             assert false;
         }
     }
@@ -222,7 +222,7 @@ public class GridCacheQueryIndexDisabledSelfTest extends GridCommonAbstractTest
                 }
             })).getAll();
         }
-        catch (IgniteException e) {
+        catch (IgniteException ignored) {
             assertTrue("Scan query should work with disabled query indexing.", false);
         }
     }
@@ -258,4 +258,4 @@ public class GridCacheQueryIndexDisabledSelfTest extends GridCommonAbstractTest
             return S.toString(SqlValue.class, this);
         }
     }
-}
\ No newline at end of file
+}

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheAbstractQuerySelfTest.java
----------------------------------------------------------------------
diff --git a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheAbstractQuerySelfTest.java b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheAbstractQuerySelfTest.java
index 7c5b472..ddffb68 100644
--- a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheAbstractQuerySelfTest.java
+++ b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheAbstractQuerySelfTest.java
@@ -66,7 +66,6 @@ import org.apache.ignite.configuration.NearCacheConfiguration;
 import org.apache.ignite.events.CacheQueryExecutedEvent;
 import org.apache.ignite.events.CacheQueryReadEvent;
 import org.apache.ignite.events.Event;
-import org.apache.ignite.internal.IgniteKernal;
 import org.apache.ignite.internal.binary.BinaryMarshaller;
 import org.apache.ignite.internal.processors.cache.distributed.replicated.IgniteCacheReplicatedQuerySelfTest;
 import org.apache.ignite.internal.processors.cache.query.QueryCursorEx;
@@ -252,7 +251,7 @@ public abstract class IgniteCacheAbstractQuerySelfTest extends GridCommonAbstrac
 
             fail();
         }
-        catch (CacheException e) {
+        catch (CacheException ignored) {
             // No-op.
         }
     }

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheLockPartitionOnAffinityRunAbstractTest.java
----------------------------------------------------------------------
diff --git a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheLockPartitionOnAffinityRunAbstractTest.java b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheLockPartitionOnAffinityRunAbstractTest.java
index 1f992e4..69ef79d 100644
--- a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheLockPartitionOnAffinityRunAbstractTest.java
+++ b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheLockPartitionOnAffinityRunAbstractTest.java
@@ -35,7 +35,6 @@ import org.apache.ignite.configuration.CacheConfiguration;
 import org.apache.ignite.configuration.IgniteConfiguration;
 import org.apache.ignite.internal.IgniteEx;
 import org.apache.ignite.internal.IgniteInternalFuture;
-import org.apache.ignite.internal.IgniteInterruptedCheckedException;
 import org.apache.ignite.internal.binary.BinaryMarshaller;
 import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion;
 import org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtLocalPartition;

http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheLockPartitionOnAffinityRunAtomicCacheOpTest.java
----------------------------------------------------------------------
diff --git a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheLockPartitionOnAffinityRunAtomicCacheOpTest.java b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheLockPartitionOnAffinityRunAtomicCacheOpTest.java
index fb90c7e..88eedaf 100644
--- a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheLockPartitionOnAffinityRunAtomicCacheOpTest.java
+++ b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheLockPartitionOnAffinityRunAtomicCacheOpTest.java
@@ -18,8 +18,6 @@
 package org.apache.ignite.internal.processors.cache;
 
 import java.util.Arrays;
-import java.util.HashMap;
-import java.util.Map;
 import java.util.concurrent.Callable;
 import java.util.concurrent.atomic.AtomicInteger;
 import org.apache.ignite.IgniteCache;
@@ -270,13 +268,10 @@ public class IgniteCacheLockPartitionOnAffinityRunAtomicCacheOpTest extends Igni
         @Override public void run() {
             log.info("Begin run " + keyBegin);
             IgniteCache cache = ignite.cache(cacheName);
-            Map<Integer, Integer> vals = new HashMap<>();
 
             for (int i = 0; i < KEYS_CNT; ++i)
                 cache.put(i + keyBegin, i + keyBegin);
-//                vals.put(i + keyBegin, i + keyBegin);
 
-//            cache.putAll(vals);
             log.info("End run " + keyBegin);
         }
     }
@@ -315,15 +310,11 @@ public class IgniteCacheLockPartitionOnAffinityRunAtomicCacheOpTest extends Igni
         @Override public void run() {
             log.info("Begin run " + keyBegin);
             IgniteCache cache = ignite.cache(Person.class.getSimpleName());
-            Map<Person.Key, Person> pers = new HashMap<>();
 
             for (int i = 0; i < KEYS_CNT; ++i) {
                 Person p = new Person(i + keyBegin, orgId);
-//                pers.put(p.createKey(), p);
                 cache.put(p.createKey(), p);
             }
-
-//            cache.putAll(pers);
         }
     }
-}
\ No newline at end of file
+}


Mime
View raw message