http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheLockPartitionOnAffinityRunTest.java ---------------------------------------------------------------------- diff --git a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheLockPartitionOnAffinityRunTest.java b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheLockPartitionOnAffinityRunTest.java index 168b25c..fbc94ed 100644 --- a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheLockPartitionOnAffinityRunTest.java +++ b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheLockPartitionOnAffinityRunTest.java @@ -30,7 +30,6 @@ import org.apache.ignite.IgniteLogger; import org.apache.ignite.cache.query.ScanQuery; import org.apache.ignite.cache.query.SqlFieldsQuery; import org.apache.ignite.cache.query.SqlQuery; -import org.apache.ignite.cluster.ClusterNode; import org.apache.ignite.compute.ComputeJobMasterLeaveAware; import org.apache.ignite.compute.ComputeTaskSession; import org.apache.ignite.internal.IgniteEx; @@ -58,19 +57,18 @@ public class IgniteCacheLockPartitionOnAffinityRunTest extends IgniteCacheLockPa private static int getPersonsCountFromPartitionMapCheckBothCaches(final IgniteEx ignite, IgniteLogger log, int orgId) throws Exception { - assertEquals(1, getOrganizationCountFromPartitionMap(ignite, log, orgId)); + assertEquals(1, getOrganizationCountFromPartitionMap(ignite, orgId)); - return getPersonsCountFromPartitionMap(ignite, log, orgId); + return getPersonsCountFromPartitionMap(ignite, orgId); } /** * @param ignite Ignite. - * @param log Logger. * @param orgId Organization id. * @return Count of found Person object with specified orgId * @throws Exception If failed. */ - private static int getOrganizationCountFromPartitionMap(final IgniteEx ignite, IgniteLogger log, + private static int getOrganizationCountFromPartitionMap(final IgniteEx ignite, int orgId) throws Exception { int part = ignite.affinity(Organization.class.getSimpleName()).partition(orgId); @@ -95,12 +93,11 @@ public class IgniteCacheLockPartitionOnAffinityRunTest extends IgniteCacheLockPa /** * @param ignite Ignite. - * @param log Logger. * @param orgId Organization id. * @return Count of found Person object with specified orgId * @throws Exception If failed. */ - private static int getPersonsCountFromPartitionMap(final IgniteEx ignite, IgniteLogger log, int orgId) + private static int getPersonsCountFromPartitionMap(final IgniteEx ignite, int orgId) throws Exception { int part = ignite.affinity(Organization.class.getSimpleName()).partition(orgId); @@ -125,11 +122,10 @@ public class IgniteCacheLockPartitionOnAffinityRunTest extends IgniteCacheLockPa /** * @param ignite Ignite. - * @param log Logger. * @param orgId Organization id. * @return Count of found Person object with specified orgId */ - private static int getPersonsCountBySqlFieldLocalQuery(final IgniteEx ignite, IgniteLogger log, int orgId) { + private static int getPersonsCountBySqlFieldLocalQuery(final IgniteEx ignite, int orgId) { List res = ignite.cache(Person.class.getSimpleName()) .query(new SqlFieldsQuery( String.format("SELECT p.id FROM \"%s\".Person as p " + @@ -142,11 +138,10 @@ public class IgniteCacheLockPartitionOnAffinityRunTest extends IgniteCacheLockPa /** * @param ignite Ignite. - * @param log Logger. * @param orgId Organization id. * @return Count of found Person object with specified orgId */ - private static int getPersonsCountBySqlFieledLocalQueryJoinOrgs(final IgniteEx ignite, IgniteLogger log, + private static int getPersonsCountBySqlFieledLocalQueryJoinOrgs(final IgniteEx ignite, int orgId) { List res = ignite.cache(Person.class.getSimpleName()) .query(new SqlFieldsQuery( @@ -162,11 +157,10 @@ public class IgniteCacheLockPartitionOnAffinityRunTest extends IgniteCacheLockPa /** * @param ignite Ignite. - * @param log Logger. * @param orgId Organization id. * @return Count of found Person object with specified orgId */ - private static int getPersonsCountBySqlLocalQuery(final IgniteEx ignite, IgniteLogger log, int orgId) { + private static int getPersonsCountBySqlLocalQuery(final IgniteEx ignite, int orgId) { List res = ignite.cache(Person.class.getSimpleName()) .query(new SqlQuery<Person.Key, Person>(Person.class, "orgId = ?").setArgs(orgId).setLocal(true)) .getAll(); @@ -176,11 +170,10 @@ public class IgniteCacheLockPartitionOnAffinityRunTest extends IgniteCacheLockPa /** * @param ignite Ignite. - * @param log Logger. * @param orgId Organization id. * @return Count of found Person object with specified orgId */ - private static int getPersonsCountByScanLocalQuery(final IgniteEx ignite, IgniteLogger log, final int orgId) { + private static int getPersonsCountByScanLocalQuery(final IgniteEx ignite, final int orgId) { List res = ignite.cache(Person.class.getSimpleName()) .query(new ScanQuery<>(new IgniteBiPredicate<Person.Key, Person>() { @Override public boolean apply(Person.Key key, Person person) { @@ -200,10 +193,10 @@ public class IgniteCacheLockPartitionOnAffinityRunTest extends IgniteCacheLockPa */ private static int getPersonsCountSingleCache(final IgniteEx ignite, IgniteLogger log, final int orgId) throws Exception { - int sqlCnt = getPersonsCountBySqlLocalQuery(ignite, log, orgId); - int sqlFieldCnt = getPersonsCountBySqlFieldLocalQuery(ignite, log, orgId); - int scanCnt = getPersonsCountByScanLocalQuery(ignite, log, orgId); - int partCnt = getPersonsCountFromPartitionMap(ignite, log, orgId); + int sqlCnt = getPersonsCountBySqlLocalQuery(ignite, orgId); + int sqlFieldCnt = getPersonsCountBySqlFieldLocalQuery(ignite, orgId); + int scanCnt = getPersonsCountByScanLocalQuery(ignite, orgId); + int partCnt = getPersonsCountFromPartitionMap(ignite, orgId); assertEquals(PERS_AT_ORG_CNT, partCnt); assertEquals(partCnt, sqlCnt); @@ -222,7 +215,7 @@ public class IgniteCacheLockPartitionOnAffinityRunTest extends IgniteCacheLockPa */ private static int getPersonsCountMultipleCache(final IgniteEx ignite, IgniteLogger log, final int orgId) throws Exception { - int sqlFieldCnt = getPersonsCountBySqlFieledLocalQueryJoinOrgs(ignite, log, orgId); + int sqlFieldCnt = getPersonsCountBySqlFieledLocalQueryJoinOrgs(ignite, orgId); int partCnt = getPersonsCountFromPartitionMapCheckBothCaches(ignite, log, orgId); assertEquals(partCnt, sqlFieldCnt); @@ -481,7 +474,7 @@ public class IgniteCacheLockPartitionOnAffinityRunTest extends IgniteCacheLockPa fail("Exception must be thrown"); } - catch (Exception e) { + catch (Exception ignored) { checkPartitionsReservations(grid(1), orgId, 0); } @@ -507,7 +500,7 @@ public class IgniteCacheLockPartitionOnAffinityRunTest extends IgniteCacheLockPa fail("Exception must be thrown"); } - catch (Exception e) { + catch (Exception ignored) { checkPartitionsReservations(grid(1), orgId, 0); } } @@ -540,7 +533,7 @@ public class IgniteCacheLockPartitionOnAffinityRunTest extends IgniteCacheLockPa fail("Error must be thrown"); } - catch (Throwable e) { + catch (Throwable ignored) { checkPartitionsReservations(grid(1), orgId, 0); } @@ -566,7 +559,7 @@ public class IgniteCacheLockPartitionOnAffinityRunTest extends IgniteCacheLockPa fail("Error must be thrown"); } - catch (Throwable e) { + catch (Throwable ignored) { checkPartitionsReservations(grid(1), orgId, 0); } } @@ -584,7 +577,7 @@ public class IgniteCacheLockPartitionOnAffinityRunTest extends IgniteCacheLockPa new JobFailUnmarshaling()); fail("Unmarshaling exception must be thrown"); } - catch (Exception e) { + catch (Exception ignored) { checkPartitionsReservations(grid(1), orgId, 0); } } @@ -615,7 +608,7 @@ public class IgniteCacheLockPartitionOnAffinityRunTest extends IgniteCacheLockPa try { Thread.sleep(1000); } - catch (InterruptedException e) { + catch (InterruptedException ignored) { // No-op. } } @@ -656,7 +649,7 @@ public class IgniteCacheLockPartitionOnAffinityRunTest extends IgniteCacheLockPa try { Thread.sleep(1000); } - catch (InterruptedException e) { + catch (InterruptedException ignored) { // No-op. } return null; @@ -708,7 +701,7 @@ public class IgniteCacheLockPartitionOnAffinityRunTest extends IgniteCacheLockPa try { Thread.sleep(1000); } - catch (InterruptedException e) { + catch (InterruptedException ignored) { // No-op. } } @@ -849,4 +842,4 @@ public class IgniteCacheLockPartitionOnAffinityRunTest extends IgniteCacheLockPa } } -} \ 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/IgniteCacheLockPartitionOnAffinityRunWithCollisionSpiTest.java ---------------------------------------------------------------------- diff --git a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheLockPartitionOnAffinityRunWithCollisionSpiTest.java b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheLockPartitionOnAffinityRunWithCollisionSpiTest.java index c0b896a..2fab000 100644 --- a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheLockPartitionOnAffinityRunWithCollisionSpiTest.java +++ b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheLockPartitionOnAffinityRunWithCollisionSpiTest.java @@ -19,28 +19,22 @@ package org.apache.ignite.internal.processors.cache; import java.util.Arrays; import java.util.Collection; -import java.util.Map; import java.util.concurrent.atomic.AtomicInteger; import org.apache.ignite.IgniteLogger; import org.apache.ignite.cluster.ClusterNode; import org.apache.ignite.configuration.IgniteConfiguration; import org.apache.ignite.internal.IgniteEx; import org.apache.ignite.internal.IgniteInternalFuture; -import org.apache.ignite.lang.IgniteFuture; import org.apache.ignite.lang.IgniteRunnable; import org.apache.ignite.resources.LoggerResource; import org.apache.ignite.spi.IgniteSpiAdapter; -import org.apache.ignite.spi.IgniteSpiContext; import org.apache.ignite.spi.IgniteSpiException; import org.apache.ignite.spi.IgniteSpiMultipleInstancesSupport; import org.apache.ignite.spi.collision.CollisionContext; import org.apache.ignite.spi.collision.CollisionExternalListener; import org.apache.ignite.spi.collision.CollisionJobContext; import org.apache.ignite.spi.collision.CollisionSpi; -import org.apache.ignite.spi.collision.jobstealing.JobStealingCollisionSpi; -import org.apache.ignite.spi.failover.always.AlwaysFailoverSpi; import org.apache.ignite.testframework.GridTestUtils; -import org.jetbrains.annotations.Nullable; /** * Test to validate https://issues.apache.org/jira/browse/IGNITE-2310 @@ -73,7 +67,7 @@ public class IgniteCacheLockPartitionOnAffinityRunWithCollisionSpiTest Arrays.asList(Organization.class.getSimpleName(), Person.class.getSimpleName()), new Integer(orgId), new TestRun(orgId)); - } catch (Exception e) { + } catch (Exception ignored) { // No-op. Swallow exceptions on run (e.g. job canceling etc.). // The test checks only correct partition release in case CollisionSpi is used. } @@ -201,4 +195,4 @@ public class IgniteCacheLockPartitionOnAffinityRunWithCollisionSpiTest // No-op. } } -} \ 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/IgniteCacheMergeSqlQuerySelfTest.java ---------------------------------------------------------------------- diff --git a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheMergeSqlQuerySelfTest.java b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheMergeSqlQuerySelfTest.java index 58d07af..32b7a12 100644 --- a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheMergeSqlQuerySelfTest.java +++ b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheMergeSqlQuerySelfTest.java @@ -19,7 +19,6 @@ package org.apache.ignite.internal.processors.cache; import org.apache.ignite.IgniteCache; import org.apache.ignite.cache.query.SqlFieldsQuery; -import org.apache.ignite.internal.binary.BinaryMarshaller; /** * http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheOffheapEvictQueryTest.java ---------------------------------------------------------------------- diff --git a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheOffheapEvictQueryTest.java b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheOffheapEvictQueryTest.java index bddef66..860f7ca 100644 --- a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheOffheapEvictQueryTest.java +++ b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheOffheapEvictQueryTest.java @@ -197,7 +197,7 @@ public class IgniteCacheOffheapEvictQueryTest extends GridCommonAbstractTest { X.println("___ all keys removed"); } - catch (IgniteFutureTimeoutCheckedException e) { + catch (IgniteFutureTimeoutCheckedException ignored) { X.println("___ timeout"); X.println("___ keys: " + keys.get()); @@ -206,4 +206,4 @@ public class IgniteCacheOffheapEvictQueryTest extends GridCommonAbstractTest { fut.get(); } } -} \ 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/IgniteCacheP2pUnmarshallingQueryErrorTest.java ---------------------------------------------------------------------- diff --git a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheP2pUnmarshallingQueryErrorTest.java b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheP2pUnmarshallingQueryErrorTest.java index c9544b9..3be84a1 100644 --- a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheP2pUnmarshallingQueryErrorTest.java +++ b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheP2pUnmarshallingQueryErrorTest.java @@ -54,7 +54,7 @@ public class IgniteCacheP2pUnmarshallingQueryErrorTest extends IgniteCacheP2pUnm fail("p2p marshalling failed, but error response was not sent"); } - catch (CacheException e) { + catch (CacheException ignored) { // No-op. } } @@ -82,7 +82,7 @@ public class IgniteCacheP2pUnmarshallingQueryErrorTest extends IgniteCacheP2pUnm fail(); } - catch (Exception e) { + catch (Exception 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/IgniteCacheUpdateSqlQuerySelfTest.java ---------------------------------------------------------------------- diff --git a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheUpdateSqlQuerySelfTest.java b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheUpdateSqlQuerySelfTest.java index 58bcaac..575f617 100644 --- a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheUpdateSqlQuerySelfTest.java +++ b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheUpdateSqlQuerySelfTest.java @@ -182,7 +182,7 @@ public class IgniteCacheUpdateSqlQuerySelfTest extends IgniteCacheAbstractSqlDml cache.query(new SqlFieldsQuery("insert into \"AllTypes\"(_key, _val, \"dateCol\", \"booleanCol\"," + "\"tsCol\") values(2, ?, '2016-11-30 12:00:00', false, DATE '2016-12-01')").setArgs(new AllTypes(2L))); - List<?> ll = cache.query(new SqlFieldsQuery("select \"primitiveIntsCol\" from \"AllTypes\"")).getAll(); + cache.query(new SqlFieldsQuery("select \"primitiveIntsCol\" from \"AllTypes\"")).getAll(); cache.query(new SqlFieldsQuery("update \"AllTypes\" set \"doubleCol\" = CAST('50' as INT)," + " \"booleanCol\" = 80, \"innerTypeCol\" = ?, \"strCol\" = PI(), \"shortCol\" = " + http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/IgniteCacheDistributedQueryCancelSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/IgniteCacheDistributedQueryCancelSelfTest.java b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/IgniteCacheDistributedQueryCancelSelfTest.java index 3fec966..ba58511 100644 --- a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/IgniteCacheDistributedQueryCancelSelfTest.java +++ b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/IgniteCacheDistributedQueryCancelSelfTest.java @@ -22,9 +22,7 @@ import java.util.List; import javax.cache.CacheException; import org.apache.ignite.Ignite; import org.apache.ignite.IgniteCache; -import org.apache.ignite.IgniteCheckedException; import org.apache.ignite.IgniteException; -import org.apache.ignite.cache.query.QueryCancelledException; import org.apache.ignite.cache.query.QueryCursor; import org.apache.ignite.cache.query.SqlFieldsQuery; import org.apache.ignite.cache.query.annotations.QuerySqlFunction; @@ -173,4 +171,4 @@ public class IgniteCacheDistributedQueryCancelSelfTest extends GridCommonAbstrac throw new IllegalArgumentException(); } } -} \ 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/distributed/near/IgniteCacheQueryNodeRestartSelfTest2.java ---------------------------------------------------------------------- diff --git a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/IgniteCacheQueryNodeRestartSelfTest2.java b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/IgniteCacheQueryNodeRestartSelfTest2.java index 154daa0..0733940 100644 --- a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/IgniteCacheQueryNodeRestartSelfTest2.java +++ b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/IgniteCacheQueryNodeRestartSelfTest2.java @@ -360,7 +360,7 @@ public class IgniteCacheQueryNodeRestartSelfTest2 extends GridCommonAbstractTest // Query thread can stuck in next page waiting loop because all nodes are left. try { fut1.get(5_000); - } catch (IgniteFutureTimeoutCheckedException e) { + } catch (IgniteFutureTimeoutCheckedException ignored) { fut1.cancel(); } @@ -427,4 +427,4 @@ public class IgniteCacheQueryNodeRestartSelfTest2 extends GridCommonAbstractTest this.companyId = companyId; } } -} \ 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/query/IgniteSqlSchemaIndexingTest.java ---------------------------------------------------------------------- diff --git a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/IgniteSqlSchemaIndexingTest.java b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/IgniteSqlSchemaIndexingTest.java index 88f1f1e..52ba246 100644 --- a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/IgniteSqlSchemaIndexingTest.java +++ b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/IgniteSqlSchemaIndexingTest.java @@ -63,10 +63,9 @@ public class IgniteSqlSchemaIndexingTest extends GridCommonAbstractTest { /** * @param name Cache name. * @param partitioned Partition or replicated cache. - * @param idxTypes Indexed types. * @return Cache configuration. */ - private static CacheConfiguration cacheConfig(String name, boolean partitioned, Class<?>... idxTypes) { + private static CacheConfiguration cacheConfig(String name, boolean partitioned) { return new CacheConfiguration() .setName(name) .setCacheMode(partitioned ? CacheMode.PARTITIONED : CacheMode.REPLICATED) @@ -91,9 +90,9 @@ public class IgniteSqlSchemaIndexingTest extends GridCommonAbstractTest { GridTestUtils.assertThrows(log, new Callable<Object>() { @Override public Object call() throws Exception { - final CacheConfiguration cfg = cacheConfig("InSensitiveCache", true, Integer.class, Integer.class) + final CacheConfiguration cfg = cacheConfig("InSensitiveCache", true) .setSqlSchema("InsensitiveCache"); - final CacheConfiguration collisionCfg = cacheConfig("InsensitiveCache", true, Integer.class, Integer.class) + final CacheConfiguration collisionCfg = cacheConfig("InsensitiveCache", true) .setSqlSchema("Insensitivecache"); IgniteConfiguration icfg = new IgniteConfiguration() .setLocalHost("127.0.0.1") @@ -114,9 +113,9 @@ public class IgniteSqlSchemaIndexingTest extends GridCommonAbstractTest { public void testCacheUnregistration() throws Exception { startGridsMultiThreaded(3, true); - final CacheConfiguration<Integer, Fact> cfg = cacheConfig("Insensitive_Cache", true, Integer.class, Fact.class) + final CacheConfiguration<Integer, Fact> cfg = cacheConfig("Insensitive_Cache", true) .setSqlSchema("Insensitive_Cache"); - final CacheConfiguration<Integer, Fact> collisionCfg = cacheConfig("InsensitiveCache", true, Integer.class, Fact.class) + final CacheConfiguration<Integer, Fact> collisionCfg = cacheConfig("InsensitiveCache", true) .setSqlSchema("Insensitive_Cache"); IgniteCache<Integer, Fact> cache = ignite(0).createCache(cfg); @@ -153,11 +152,11 @@ public class IgniteSqlSchemaIndexingTest extends GridCommonAbstractTest { public void testSchemaEscapeAll() throws Exception { startGridsMultiThreaded(3, true); - final CacheConfiguration<Integer, Fact> cfg = cacheConfig("simpleSchema", true, Integer.class, Fact.class) + final CacheConfiguration<Integer, Fact> cfg = cacheConfig("simpleSchema", true) .setSqlSchema("SchemaName1") .setSqlEscapeAll(true); - final CacheConfiguration<Integer, Fact> cfgEsc = cacheConfig("escapedSchema", true, Integer.class, Fact.class) + final CacheConfiguration<Integer, Fact> cfgEsc = cacheConfig("escapedSchema", true) .setSqlSchema("\"SchemaName2\"") .setSqlEscapeAll(true); http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/IgniteSqlSplitterSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/IgniteSqlSplitterSelfTest.java b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/IgniteSqlSplitterSelfTest.java index e72c9cb..06afe7c 100644 --- a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/IgniteSqlSplitterSelfTest.java +++ b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/IgniteSqlSplitterSelfTest.java @@ -36,8 +36,6 @@ import org.apache.ignite.cache.CachePeekMode; import org.apache.ignite.cache.affinity.AffinityKeyMapped; import org.apache.ignite.cache.affinity.Affinity; import org.apache.ignite.cache.query.QueryCursor; -import org.apache.ignite.cache.affinity.Affinity; -import org.apache.ignite.cache.query.QueryCursor; import org.apache.ignite.cache.query.SqlFieldsQuery; import org.apache.ignite.cache.query.annotations.QuerySqlField; import org.apache.ignite.cluster.ClusterNode; @@ -1584,4 +1582,4 @@ public class IgniteSqlSplitterSelfTest extends GridCommonAbstractTest { @QuerySqlField private int goodId; } -} \ 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/query/h2/GridIndexingSpiAbstractSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/h2/GridIndexingSpiAbstractSelfTest.java b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/h2/GridIndexingSpiAbstractSelfTest.java index 512001f..e412828 100644 --- a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/h2/GridIndexingSpiAbstractSelfTest.java +++ b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/h2/GridIndexingSpiAbstractSelfTest.java @@ -236,7 +236,7 @@ public abstract class GridIndexingSpiAbstractSelfTest extends GridCommonAbstract fail("Enumerations of aliases in select block must be prohibited"); } - catch (IgniteCheckedException e) { + catch (IgniteCheckedException ignored) { // all fine } @@ -713,4 +713,4 @@ public abstract class GridIndexingSpiAbstractSelfTest extends GridCommonAbstract throw new UnsupportedOperationException(); } } -} \ 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/query/h2/sql/GridQueryParsingTest.java ---------------------------------------------------------------------- diff --git a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/h2/sql/GridQueryParsingTest.java b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/h2/sql/GridQueryParsingTest.java index 537ccdf..b909b36 100644 --- a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/h2/sql/GridQueryParsingTest.java +++ b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/h2/sql/GridQueryParsingTest.java @@ -39,12 +39,8 @@ import org.apache.ignite.spi.discovery.tcp.ipfinder.TcpDiscoveryIpFinder; import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder; import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest; import org.h2.command.Prepared; -import org.h2.command.dml.Query; -import org.h2.command.dml.Update; import org.h2.engine.Session; -import org.h2.expression.Expression; import org.h2.jdbc.JdbcConnection; -import org.h2.util.StringUtils; import static org.apache.ignite.cache.CacheRebalanceMode.SYNC; import static org.apache.ignite.cache.CacheWriteSynchronizationMode.FULL_SYNC; http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/jms11/src/main/java/org/apache/ignite/stream/jms11/JmsStreamer.java ---------------------------------------------------------------------- diff --git a/modules/jms11/src/main/java/org/apache/ignite/stream/jms11/JmsStreamer.java b/modules/jms11/src/main/java/org/apache/ignite/stream/jms11/JmsStreamer.java index cce493e..1b203ad 100644 --- a/modules/jms11/src/main/java/org/apache/ignite/stream/jms11/JmsStreamer.java +++ b/modules/jms11/src/main/java/org/apache/ignite/stream/jms11/JmsStreamer.java @@ -242,7 +242,7 @@ public class JmsStreamer<T extends Message, K, V> extends StreamAdapter<T, K, V> session + "]"); } } - catch (JMSException e) { + catch (JMSException ignored) { log.warning("Error while committing session: from batch time-based completion " + "[session=" + session + "]"); } @@ -536,4 +536,4 @@ public class JmsStreamer<T extends Message, K, V> extends StreamAdapter<T, K, V> } } -} \ No newline at end of file +} http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/kafka/src/main/java/org/apache/ignite/stream/kafka/KafkaStreamer.java ---------------------------------------------------------------------- diff --git a/modules/kafka/src/main/java/org/apache/ignite/stream/kafka/KafkaStreamer.java b/modules/kafka/src/main/java/org/apache/ignite/stream/kafka/KafkaStreamer.java index 73820b7..ed3530b 100644 --- a/modules/kafka/src/main/java/org/apache/ignite/stream/kafka/KafkaStreamer.java +++ b/modules/kafka/src/main/java/org/apache/ignite/stream/kafka/KafkaStreamer.java @@ -167,7 +167,7 @@ public class KafkaStreamer<K, V> extends StreamAdapter<MessageAndMetadata<byte[] try { Thread.sleep(retryTimeout); } - catch (InterruptedException ie) { + catch (InterruptedException ignored) { // No-op. } } @@ -194,10 +194,10 @@ public class KafkaStreamer<K, V> extends StreamAdapter<MessageAndMetadata<byte[] if (log.isDebugEnabled()) log.debug("Timed out waiting for consumer threads to shut down, exiting uncleanly."); } - catch (InterruptedException e) { + catch (InterruptedException ignored) { if (log.isDebugEnabled()) log.debug("Interrupted during shutdown, exiting uncleanly."); } } } -} \ No newline at end of file +} http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/kafka/src/test/java/org/apache/ignite/stream/kafka/TestKafkaBroker.java ---------------------------------------------------------------------- diff --git a/modules/kafka/src/test/java/org/apache/ignite/stream/kafka/TestKafkaBroker.java b/modules/kafka/src/test/java/org/apache/ignite/stream/kafka/TestKafkaBroker.java index 4c5dc51..d7b63f3 100644 --- a/modules/kafka/src/test/java/org/apache/ignite/stream/kafka/TestKafkaBroker.java +++ b/modules/kafka/src/test/java/org/apache/ignite/stream/kafka/TestKafkaBroker.java @@ -133,7 +133,7 @@ public class TestKafkaBroker { try { zkServer.stop(); } - catch (IOException e) { + catch (IOException ignored) { // No-op. } } http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/kafka/src/test/java/org/apache/ignite/stream/kafka/connect/IgniteSourceConnectorTest.java ---------------------------------------------------------------------- diff --git a/modules/kafka/src/test/java/org/apache/ignite/stream/kafka/connect/IgniteSourceConnectorTest.java b/modules/kafka/src/test/java/org/apache/ignite/stream/kafka/connect/IgniteSourceConnectorTest.java index a3ce10e..f47450f 100644 --- a/modules/kafka/src/test/java/org/apache/ignite/stream/kafka/connect/IgniteSourceConnectorTest.java +++ b/modules/kafka/src/test/java/org/apache/ignite/stream/kafka/connect/IgniteSourceConnectorTest.java @@ -296,7 +296,7 @@ public class IgniteSourceConnectorTest extends GridCommonAbstractTest { } }, 5_000)); } - catch (WakeupException e) { + catch (WakeupException ignored) { // ignore for shutdown. } finally { http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/mqtt/src/test/java/org/apache/ignite/stream/mqtt/IgniteMqttStreamerTest.java ---------------------------------------------------------------------- diff --git a/modules/mqtt/src/test/java/org/apache/ignite/stream/mqtt/IgniteMqttStreamerTest.java b/modules/mqtt/src/test/java/org/apache/ignite/stream/mqtt/IgniteMqttStreamerTest.java index 92a530d..49e1f71 100644 --- a/modules/mqtt/src/test/java/org/apache/ignite/stream/mqtt/IgniteMqttStreamerTest.java +++ b/modules/mqtt/src/test/java/org/apache/ignite/stream/mqtt/IgniteMqttStreamerTest.java @@ -158,7 +158,7 @@ public class IgniteMqttStreamerTest extends GridCommonAbstractTest { try { streamer.stop(); } - catch (Exception e) { + catch (Exception ignored) { // ignore if already stopped } @@ -483,7 +483,7 @@ public class IgniteMqttStreamerTest extends GridCommonAbstractTest { try { streamer.start(); } - catch (Exception e) { + catch (Exception ignored) { return; } http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/osgi/src/main/java/org/apache/ignite/osgi/classloaders/BundleDelegatingClassLoader.java ---------------------------------------------------------------------- diff --git a/modules/osgi/src/main/java/org/apache/ignite/osgi/classloaders/BundleDelegatingClassLoader.java b/modules/osgi/src/main/java/org/apache/ignite/osgi/classloaders/BundleDelegatingClassLoader.java index 07c0682..92919b9 100644 --- a/modules/osgi/src/main/java/org/apache/ignite/osgi/classloaders/BundleDelegatingClassLoader.java +++ b/modules/osgi/src/main/java/org/apache/ignite/osgi/classloaders/BundleDelegatingClassLoader.java @@ -97,14 +97,14 @@ public class BundleDelegatingClassLoader extends ClassLoader { try { cls = findClass(name); } - catch (ClassNotFoundException e) { + catch (ClassNotFoundException ignored) { if (clsLdr == null) throw classNotFoundException(name); try { cls = clsLdr.loadClass(name); } - catch (ClassNotFoundException e2) { + catch (ClassNotFoundException ignored2) { throw classNotFoundException(name); } http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/osgi/src/main/java/org/apache/ignite/osgi/classloaders/ContainerSweepClassLoader.java ---------------------------------------------------------------------- diff --git a/modules/osgi/src/main/java/org/apache/ignite/osgi/classloaders/ContainerSweepClassLoader.java b/modules/osgi/src/main/java/org/apache/ignite/osgi/classloaders/ContainerSweepClassLoader.java index e2e773a..0a4cdc4 100644 --- a/modules/osgi/src/main/java/org/apache/ignite/osgi/classloaders/ContainerSweepClassLoader.java +++ b/modules/osgi/src/main/java/org/apache/ignite/osgi/classloaders/ContainerSweepClassLoader.java @@ -77,7 +77,7 @@ public class ContainerSweepClassLoader extends BundleDelegatingClassLoader { cls = super.loadClass(name, resolve); return cls; } - catch (ClassNotFoundException e) { + catch (ClassNotFoundException ignored) { // Continue. } @@ -119,7 +119,7 @@ public class ContainerSweepClassLoader extends BundleDelegatingClassLoader { cls = b.loadClass(name); break; } - catch (ClassNotFoundException e) { + catch (ClassNotFoundException ignored) { // No-op. } } http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/spark/src/test/java/org/apache/ignite/spark/JavaStandaloneIgniteRDDSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/spark/src/test/java/org/apache/ignite/spark/JavaStandaloneIgniteRDDSelfTest.java b/modules/spark/src/test/java/org/apache/ignite/spark/JavaStandaloneIgniteRDDSelfTest.java index 343158b..e9d97a4 100644 --- a/modules/spark/src/test/java/org/apache/ignite/spark/JavaStandaloneIgniteRDDSelfTest.java +++ b/modules/spark/src/test/java/org/apache/ignite/spark/JavaStandaloneIgniteRDDSelfTest.java @@ -39,7 +39,6 @@ import org.apache.spark.sql.DataFrame; import org.apache.spark.sql.Row; import scala.Tuple2; -import java.io.Serializable; import java.lang.reflect.Field; import java.math.BigDecimal; import java.util.List; @@ -362,4 +361,4 @@ public class JavaStandaloneIgniteRDDSelfTest extends GridCommonAbstractTest { return t._2(); } } -} \ No newline at end of file +} http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/spring/src/main/java/org/apache/ignite/internal/util/spring/IgniteSpringHelperImpl.java ---------------------------------------------------------------------- diff --git a/modules/spring/src/main/java/org/apache/ignite/internal/util/spring/IgniteSpringHelperImpl.java b/modules/spring/src/main/java/org/apache/ignite/internal/util/spring/IgniteSpringHelperImpl.java index 7523106..a14f6ba 100644 --- a/modules/spring/src/main/java/org/apache/ignite/internal/util/spring/IgniteSpringHelperImpl.java +++ b/modules/spring/src/main/java/org/apache/ignite/internal/util/spring/IgniteSpringHelperImpl.java @@ -166,7 +166,7 @@ public class IgniteSpringHelperImpl implements IgniteSpringHelper { try { return (T)springCtx.getBean(beanName); } - catch (NoSuchBeanDefinitionException e) { + catch (NoSuchBeanDefinitionException ignored) { throw new IgniteCheckedException("Spring bean with provided name doesn't exist [url=" + url + ", beanName=" + beanName + ']'); } @@ -199,7 +199,7 @@ public class IgniteSpringHelperImpl implements IgniteSpringHelper { try { return (T)springCtx.getBean(beanName); } - catch (NoSuchBeanDefinitionException e) { + catch (NoSuchBeanDefinitionException ignored) { throw new IgniteCheckedException("Spring bean with provided name doesn't exist " + ", beanName=" + beanName + ']'); } @@ -216,7 +216,7 @@ public class IgniteSpringHelperImpl implements IgniteSpringHelper { try { return (T)springCtx.getBean(beanName); } - catch (NoSuchBeanDefinitionException e) { + catch (NoSuchBeanDefinitionException ignored) { throw new IgniteCheckedException("Spring bean with provided name doesn't exist " + ", beanName=" + beanName + ']'); } @@ -505,4 +505,4 @@ public class IgniteSpringHelperImpl implements IgniteSpringHelper { return springCtx; } -} \ No newline at end of file +} http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/spring/src/test/java/org/apache/ignite/internal/GridFactorySelfTest.java ---------------------------------------------------------------------- diff --git a/modules/spring/src/test/java/org/apache/ignite/internal/GridFactorySelfTest.java b/modules/spring/src/test/java/org/apache/ignite/internal/GridFactorySelfTest.java index e1db958..bb00661 100644 --- a/modules/spring/src/test/java/org/apache/ignite/internal/GridFactorySelfTest.java +++ b/modules/spring/src/test/java/org/apache/ignite/internal/GridFactorySelfTest.java @@ -134,7 +134,7 @@ public class GridFactorySelfTest extends GridCommonAbstractTest { fail(); } - catch (IgniteException expected) { + catch (IgniteException ignored) { // No-op. } } http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/spring/src/test/java/org/apache/ignite/internal/IgniteDynamicCacheConfigTest.java ---------------------------------------------------------------------- diff --git a/modules/spring/src/test/java/org/apache/ignite/internal/IgniteDynamicCacheConfigTest.java b/modules/spring/src/test/java/org/apache/ignite/internal/IgniteDynamicCacheConfigTest.java index 4b735d5..6131193 100644 --- a/modules/spring/src/test/java/org/apache/ignite/internal/IgniteDynamicCacheConfigTest.java +++ b/modules/spring/src/test/java/org/apache/ignite/internal/IgniteDynamicCacheConfigTest.java @@ -205,7 +205,7 @@ public class IgniteDynamicCacheConfigTest extends GridCommonAbstractTest { fail(); } - catch (IgniteException e) { + catch (IgniteException ignored) { // No-op. } } @@ -245,4 +245,4 @@ public class IgniteDynamicCacheConfigTest extends GridCommonAbstractTest { private NearCacheConfiguration loadNear(String path) { return Ignition.loadSpringBean(path, "nearCache-configuration"); } -} \ No newline at end of file +} http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/spring/src/test/java/org/apache/ignite/transactions/spring/GridSpringTransactionManagerSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/spring/src/test/java/org/apache/ignite/transactions/spring/GridSpringTransactionManagerSelfTest.java b/modules/spring/src/test/java/org/apache/ignite/transactions/spring/GridSpringTransactionManagerSelfTest.java index 02d6e88..35a0eda 100644 --- a/modules/spring/src/test/java/org/apache/ignite/transactions/spring/GridSpringTransactionManagerSelfTest.java +++ b/modules/spring/src/test/java/org/apache/ignite/transactions/spring/GridSpringTransactionManagerSelfTest.java @@ -128,7 +128,7 @@ public class GridSpringTransactionManagerSelfTest extends GridCommonAbstractTest try { service.putWithError(c, entryCnt); } - catch (Exception e) { + catch (Exception ignored) { // No-op. } http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/tools/src/main/java/org/apache/ignite/tools/classgen/ClassesGenerator.java ---------------------------------------------------------------------- diff --git a/modules/tools/src/main/java/org/apache/ignite/tools/classgen/ClassesGenerator.java b/modules/tools/src/main/java/org/apache/ignite/tools/classgen/ClassesGenerator.java index 369e318..360bb2a 100644 --- a/modules/tools/src/main/java/org/apache/ignite/tools/classgen/ClassesGenerator.java +++ b/modules/tools/src/main/java/org/apache/ignite/tools/classgen/ClassesGenerator.java @@ -240,7 +240,7 @@ public class ClassesGenerator { if (!Modifier.isPublic(cons.getModifiers())) errs.add("Default constructor in Externalizable class is not public: " + cls.getName()); } - catch (NoSuchMethodException e) { + catch (NoSuchMethodException ignored) { errs.add("No default constructor in Externalizable class: " + cls.getName()); } } http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/twitter/src/test/java/org/apache/ignite/stream/twitter/IgniteTwitterStreamerTest.java ---------------------------------------------------------------------- diff --git a/modules/twitter/src/test/java/org/apache/ignite/stream/twitter/IgniteTwitterStreamerTest.java b/modules/twitter/src/test/java/org/apache/ignite/stream/twitter/IgniteTwitterStreamerTest.java index 4ba07ff..f6d51a7 100644 --- a/modules/twitter/src/test/java/org/apache/ignite/stream/twitter/IgniteTwitterStreamerTest.java +++ b/modules/twitter/src/test/java/org/apache/ignite/stream/twitter/IgniteTwitterStreamerTest.java @@ -127,7 +127,7 @@ public class IgniteTwitterStreamerTest extends GridCommonAbstractTest { fail("Successful start of already started Twitter Streamer"); } - catch (IgniteException ex) { + catch (IgniteException ignored) { // No-op. } @@ -145,7 +145,7 @@ public class IgniteTwitterStreamerTest extends GridCommonAbstractTest { fail("Successful stop of already stopped Twitter Streamer"); } - catch (IgniteException ex) { + catch (IgniteException ignored) { // No-op. } http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/urideploy/src/test/java/org/apache/ignite/spi/deployment/uri/GridUriDeploymentFileProcessorSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/urideploy/src/test/java/org/apache/ignite/spi/deployment/uri/GridUriDeploymentFileProcessorSelfTest.java b/modules/urideploy/src/test/java/org/apache/ignite/spi/deployment/uri/GridUriDeploymentFileProcessorSelfTest.java index cbcac9c..fad7cb2 100644 --- a/modules/urideploy/src/test/java/org/apache/ignite/spi/deployment/uri/GridUriDeploymentFileProcessorSelfTest.java +++ b/modules/urideploy/src/test/java/org/apache/ignite/spi/deployment/uri/GridUriDeploymentFileProcessorSelfTest.java @@ -21,7 +21,6 @@ import java.io.File; import java.util.ArrayList; import java.util.List; import org.apache.ignite.IgniteCheckedException; -import org.apache.ignite.internal.util.lang.GridAbsPredicate; import org.apache.ignite.internal.util.lang.GridAbsPredicateX; import org.apache.ignite.internal.util.typedef.internal.U; import org.apache.ignite.testframework.GridTestUtils; @@ -170,4 +169,4 @@ public class GridUriDeploymentFileProcessorSelfTest extends GridUriDeploymentAbs return uriList; } -} \ No newline at end of file +} http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/web/src/main/java/org/apache/ignite/cache/websession/WebSessionV2.java ---------------------------------------------------------------------- diff --git a/modules/web/src/main/java/org/apache/ignite/cache/websession/WebSessionV2.java b/modules/web/src/main/java/org/apache/ignite/cache/websession/WebSessionV2.java index bdd57c6..1008b58 100644 --- a/modules/web/src/main/java/org/apache/ignite/cache/websession/WebSessionV2.java +++ b/modules/web/src/main/java/org/apache/ignite/cache/websession/WebSessionV2.java @@ -292,7 +292,7 @@ class WebSessionV2 implements HttpSession { try { genuineSes.invalidate(); } - catch (IllegalStateException e) { + catch (IllegalStateException ignored) { // Already invalidated, keep going. } } http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/web/src/test/java/org/apache/ignite/internal/websession/WebSessionSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/web/src/test/java/org/apache/ignite/internal/websession/WebSessionSelfTest.java b/modules/web/src/test/java/org/apache/ignite/internal/websession/WebSessionSelfTest.java index bfa12a2..f6a16e2 100644 --- a/modules/web/src/test/java/org/apache/ignite/internal/websession/WebSessionSelfTest.java +++ b/modules/web/src/test/java/org/apache/ignite/internal/websession/WebSessionSelfTest.java @@ -158,7 +158,7 @@ public class WebSessionSelfTest extends GridCommonAbstractTest { assertNotNull(sesId); } - Ignite ignite2 = Ignition.start(srvCfg2); + Ignition.start(srvCfg2); stopGrid(ignite.name()); @@ -305,7 +305,7 @@ public class WebSessionSelfTest extends GridCommonAbstractTest { */ private void testSessionRenewalDuringLogin(String cfg) throws Exception { Server srv = null; - String sesId = null; + String sesId; try { srv = startServerWithLoginService(TEST_JETTY_PORT, cfg, null, new SessionLoginServlet()); @@ -1072,7 +1072,7 @@ public class WebSessionSelfTest extends GridCommonAbstractTest { req.getSession().invalidate(); res.getWriter().println("invalidated"); } - catch (Exception e) { + catch (Exception ignored) { res.getWriter().println("failed"); } http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/yarn/src/main/java/org/apache/ignite/yarn/ApplicationMaster.java ---------------------------------------------------------------------- diff --git a/modules/yarn/src/main/java/org/apache/ignite/yarn/ApplicationMaster.java b/modules/yarn/src/main/java/org/apache/ignite/yarn/ApplicationMaster.java index 609f29b..238ed06 100644 --- a/modules/yarn/src/main/java/org/apache/ignite/yarn/ApplicationMaster.java +++ b/modules/yarn/src/main/java/org/apache/ignite/yarn/ApplicationMaster.java @@ -319,7 +319,7 @@ public class ApplicationMaster implements AMRMClientAsync.CallbackHandler { TimeUnit.MILLISECONDS.sleep(schedulerTimeout); } } - catch (InterruptedException e) { + catch (InterruptedException ignored) { // Un-register with ResourceManager rmClient.unregisterApplicationMaster(FinalApplicationStatus.KILLED, "", ""); @@ -430,4 +430,4 @@ public class ApplicationMaster implements AMRMClientAsync.CallbackHandler { public Map<ContainerId, IgniteContainer> getContainers() { return containers; } -} \ No newline at end of file +} http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/yarn/src/main/java/org/apache/ignite/yarn/IgniteProvider.java ---------------------------------------------------------------------- diff --git a/modules/yarn/src/main/java/org/apache/ignite/yarn/IgniteProvider.java b/modules/yarn/src/main/java/org/apache/ignite/yarn/IgniteProvider.java index 158a89a..08913c2 100644 --- a/modules/yarn/src/main/java/org/apache/ignite/yarn/IgniteProvider.java +++ b/modules/yarn/src/main/java/org/apache/ignite/yarn/IgniteProvider.java @@ -154,7 +154,7 @@ public class IgniteProvider { try { fileStatuses = fs.listStatus(new Path(folder)); } - catch (FileNotFoundException e) { + catch (FileNotFoundException ignored) { // Ignore. Folder doesn't exist. } catch (Exception e) { @@ -344,4 +344,4 @@ public class IgniteProvider { return -1; } } -} \ No newline at end of file +} http://git-wip-us.apache.org/repos/asf/ignite/blob/529a5455/modules/zookeeper/src/test/java/org/apache/ignite/spi/discovery/tcp/ipfinder/zk/ZookeeperIpFinderTest.java ---------------------------------------------------------------------- diff --git a/modules/zookeeper/src/test/java/org/apache/ignite/spi/discovery/tcp/ipfinder/zk/ZookeeperIpFinderTest.java b/modules/zookeeper/src/test/java/org/apache/ignite/spi/discovery/tcp/ipfinder/zk/ZookeeperIpFinderTest.java index 601323c..7d50149 100644 --- a/modules/zookeeper/src/test/java/org/apache/ignite/spi/discovery/tcp/ipfinder/zk/ZookeeperIpFinderTest.java +++ b/modules/zookeeper/src/test/java/org/apache/ignite/spi/discovery/tcp/ipfinder/zk/ZookeeperIpFinderTest.java @@ -366,7 +366,7 @@ public class ZookeeperIpFinderTest extends GridCommonAbstractTest { try { return 0 == zkCurator.getChildren().forPath(SERVICES_IGNITE_ZK_PATH).size(); } - catch (Exception e) { + catch (Exception ignored) { return false; } }
