You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by yz...@apache.org on 2017/02/06 10:11:24 UTC
[11/32] ignite git commit: IGNITE-4612 Minor code cleanup
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;
}
}