Repository: ignite Updated Branches: refs/heads/master a0fc6ee60 -> 794e1d364
IGNITE-5104: fixing code style issues Reviewed and merged by Denis Magda. Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/794e1d36 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/794e1d36 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/794e1d36 Branch: refs/heads/master Commit: 794e1d3643021319e7aaa0707b288bf6791b44be Parents: a0fc6ee Author: Nikita Amelchev <nsamelc...@gmail.com> Authored: Wed May 17 22:42:07 2017 -0400 Committer: Denis Magda <dma...@gridgain.com> Committed: Wed May 17 22:42:07 2017 -0400 ---------------------------------------------------------------------- .../ClientAbstractMultiNodeSelfTest.java | 3 +- .../client/impl/GridClientDataImpl.java | 3 +- .../internal/executor/GridExecutorService.java | 3 +- .../deployment/GridDeploymentClassLoader.java | 3 +- .../cache/database/freelist/FreeListImpl.java | 3 +- .../cache/database/freelist/PagesList.java | 3 +- .../cache/database/tree/util/PageHandler.java | 3 +- .../jobmetrics/GridJobMetricsProcessor.java | 4 +- .../internal/util/gridify/GridifyUtils.java | 6 +- .../offheap/unsafe/GridOffHeapSnapTreeMap.java | 3 +- .../local/LocalAffinityFunctionTest.java | 6 +- .../store/GridCacheBalancingStoreSelfTest.java | 32 ++------ .../internal/ClusterNodeMetricsSelfTest.java | 3 +- .../ComputeJobCancelWithServiceSelfTest.java | 3 +- .../IgniteComputeEmptyClusterGroupTest.java | 6 +- .../MarshallerContextLockingSelfTest.java | 3 +- .../GridCacheBinaryObjectsAbstractSelfTest.java | 3 +- .../IgniteCountDownLatchAbstractSelfTest.java | 3 +- .../IgniteDataStructureUniqueNameTest.java | 3 +- .../IgniteCacheTxIteratorSelfTest.java | 21 ++--- ...eContinuousQueryReplicatedTxOneNodeTest.java | 3 +- ...heWriteBehindStoreMultithreadedSelfTest.java | 3 +- ...gniteComputeConfigVariationsFullApiTest.java | 84 +++++--------------- ...gfsSecondaryFileSystemInjectionSelfTest.java | 6 +- .../GridServiceProcessorAbstractSelfTest.java | 3 +- ...GridUnsafeDataOutputArraySizingSelfTest.java | 4 +- .../IpcSharedMemoryBenchmarkReader.java | 3 +- .../offheap/GridOffHeapMapAbstractSelfTest.java | 3 +- .../unsafe/GridUnsafeMemorySelfTest.java | 3 +- .../marshaller/GridMarshallerAbstractTest.java | 6 +- .../TcpCommunicationSpiFaultyClientTest.java | 3 +- .../tests/p2p/P2PTestTaskExternalPath2.java | 4 +- .../sink/flink/FlinkIgniteSinkSelfTest.java | 9 +-- .../HadoopIgfs20FileSystemAbstractSelfTest.java | 3 +- .../IgniteHadoopFileSystemAbstractSelfTest.java | 6 +- .../taskexecutor/HadoopExecutorServiceTest.java | 3 +- .../GridCacheQueryIndexDisabledSelfTest.java | 4 +- ...butedPartitionQueryNodeRestartsSelfTest.java | 6 +- .../kafka/connect/IgniteSinkConnectorTest.java | 3 +- .../connect/IgniteSourceConnectorTest.java | 3 +- .../log4j2/GridLog4j2InitializedTest.java | 3 +- .../log4j2/GridLog4j2LoggingFileTest.java | 3 +- .../org/apache/ignite/mesos/IgniteTask.java | 3 +- .../spring/SpringTransactionManager.java | 32 ++------ .../internal/IgniteDynamicCacheConfigTest.java | 4 +- .../GridSpringTransactionManagerSelfTest.java | 42 +++------- .../spi/deployment/uri/UriDeploymentSpi.java | 6 +- .../scanners/http/UriDeploymentHttpScanner.java | 3 +- .../uri/GridUriDeploymentMd5CheckSelfTest.java | 9 +-- 49 files changed, 111 insertions(+), 273 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/clients/src/test/java/org/apache/ignite/internal/client/integration/ClientAbstractMultiNodeSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/clients/src/test/java/org/apache/ignite/internal/client/integration/ClientAbstractMultiNodeSelfTest.java b/modules/clients/src/test/java/org/apache/ignite/internal/client/integration/ClientAbstractMultiNodeSelfTest.java index c97d978..6023ab0 100644 --- a/modules/clients/src/test/java/org/apache/ignite/internal/client/integration/ClientAbstractMultiNodeSelfTest.java +++ b/modules/clients/src/test/java/org/apache/ignite/internal/client/integration/ClientAbstractMultiNodeSelfTest.java @@ -288,8 +288,7 @@ public abstract class ClientAbstractMultiNodeSelfTest extends GridCommonAbstract }, GridClientException.class, null); GridTestUtils.assertThrows(log(), new Callable<Object>() { - @Override - public Object call() throws Exception { + @Override public Object call() throws Exception { return singleNodePrj.projection(targetFilter); } }, GridClientException.class, null); http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/core/src/main/java/org/apache/ignite/internal/client/impl/GridClientDataImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/client/impl/GridClientDataImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/client/impl/GridClientDataImpl.java index b97f3e3..a2a9754 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/client/impl/GridClientDataImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/client/impl/GridClientDataImpl.java @@ -191,8 +191,7 @@ public class GridClientDataImpl extends GridClientAbstractProjection<GridClientD A.notNull(key, "key"); return withReconnectHandling(new ClientProjectionClosure<Boolean>() { - @Override - public GridClientFuture<Boolean> apply(GridClientConnection conn, UUID destNodeId) + @Override public GridClientFuture<Boolean> apply(GridClientConnection conn, UUID destNodeId) throws GridClientConnectionResetException, GridClientClosedException { return conn.cacheRemove(cacheName, key, flags, destNodeId); } http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/core/src/main/java/org/apache/ignite/internal/executor/GridExecutorService.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/executor/GridExecutorService.java b/modules/core/src/main/java/org/apache/ignite/internal/executor/GridExecutorService.java index e8db977..bd34599 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/executor/GridExecutorService.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/executor/GridExecutorService.java @@ -337,8 +337,7 @@ public class GridExecutorService implements ExecutorService, Externalizable { * } * </pre> */ - @Override - public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) + @Override public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) throws InterruptedException { A.notNull(tasks, "tasks != null"); A.ensure(timeout >= 0, "timeout >= 0"); http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeploymentClassLoader.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeploymentClassLoader.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeploymentClassLoader.java index 292f16e..78f1066 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeploymentClassLoader.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/GridDeploymentClassLoader.java @@ -329,8 +329,7 @@ class GridDeploymentClassLoader extends ClassLoader implements GridDeploymentInf * @param nodeId Participating node ID. * @return Removed class loader ID. */ - @Nullable - IgniteUuid unregister(UUID nodeId) { + @Nullable IgniteUuid unregister(UUID nodeId) { assert nodeId != null; synchronized (mux) { http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/database/freelist/FreeListImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/database/freelist/FreeListImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/database/freelist/FreeListImpl.java index cb68f7b..fadd685 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/database/freelist/FreeListImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/database/freelist/FreeListImpl.java @@ -259,8 +259,7 @@ public class FreeListImpl extends PagesList implements FreeList, ReuseList { * */ private final class RemoveRowHandler extends PageHandler<Void, Long> { - @Override - public Long run( + @Override public Long run( int cacheId, long pageId, long page, http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/database/freelist/PagesList.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/database/freelist/PagesList.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/database/freelist/PagesList.java index 98a55bd..d5d4c7c 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/database/freelist/PagesList.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/database/freelist/PagesList.java @@ -89,8 +89,7 @@ public abstract class PagesList extends DataStructure { * */ private final class CutTail extends PageHandler<Void, Boolean> { - @Override - public Boolean run( + @Override public Boolean run( int cacheId, long pageId, long page, http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/database/tree/util/PageHandler.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/database/tree/util/PageHandler.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/database/tree/util/PageHandler.java index 0ca2abc..0d331e7 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/database/tree/util/PageHandler.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/database/tree/util/PageHandler.java @@ -34,8 +34,7 @@ import static java.lang.Boolean.TRUE; public abstract class PageHandler<X, R> { /** */ private static final PageHandler<Void, Boolean> NO_OP = new PageHandler<Void, Boolean>() { - @Override - public Boolean run(int cacheId, long pageId, long page, long pageAddr, PageIO io, Boolean walPlc, + @Override public Boolean run(int cacheId, long pageId, long page, long pageAddr, PageIO io, Boolean walPlc, Void arg, int intArg) throws IgniteCheckedException { return Boolean.TRUE; http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/core/src/main/java/org/apache/ignite/internal/processors/jobmetrics/GridJobMetricsProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/jobmetrics/GridJobMetricsProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/jobmetrics/GridJobMetricsProcessor.java index 50e7b83..e7fe8ae 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/jobmetrics/GridJobMetricsProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/jobmetrics/GridJobMetricsProcessor.java @@ -324,9 +324,7 @@ public class GridJobMetricsProcessor extends GridProcessorAdapter { /** */ private GridJobMetricsSnapshot lastSnapshot; - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override public boolean collect(GridJobMetricsSnapshot s) { assert s != null; http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/core/src/main/java/org/apache/ignite/internal/util/gridify/GridifyUtils.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/gridify/GridifyUtils.java b/modules/core/src/main/java/org/apache/ignite/internal/util/gridify/GridifyUtils.java index b0640c2..7c9ef00 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/gridify/GridifyUtils.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/gridify/GridifyUtils.java @@ -296,8 +296,7 @@ public final class GridifyUtils { * @return Collection of parameters or {@code null} for unknown object. */ @SuppressWarnings({"unchecked"}) - @Nullable - public static Collection parameterToCollection(Object arg) { + @Nullable public static Collection parameterToCollection(Object arg) { if (arg instanceof Collection) return (Collection)arg; else if (arg instanceof Iterator) { @@ -357,8 +356,7 @@ public final class GridifyUtils { * @return Object applied for method. */ @SuppressWarnings({"unchecked"}) - @Nullable - public static Object collectionToParameter(Class<?> paramCls, Collection data) { + @Nullable public static Object collectionToParameter(Class<?> paramCls, Collection data) { if (Collection.class.equals(paramCls)) return data; else if (Iterable.class.equals(paramCls)) http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/core/src/main/java/org/apache/ignite/internal/util/offheap/unsafe/GridOffHeapSnapTreeMap.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/offheap/unsafe/GridOffHeapSnapTreeMap.java b/modules/core/src/main/java/org/apache/ignite/internal/util/offheap/unsafe/GridOffHeapSnapTreeMap.java index 6a97f9e..518e303 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/offheap/unsafe/GridOffHeapSnapTreeMap.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/offheap/unsafe/GridOffHeapSnapTreeMap.java @@ -4450,8 +4450,7 @@ public class GridOffHeapSnapTreeMap<K extends GridOffHeapSmartPointer, V extends * @param key Key. * @return Taken lock. */ - @Nullable - public Lock lock(Object key) { + @Nullable public Lock lock(Object key) { Thread th = Thread.currentThread(); Lock l = new Lock(key, th); http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/core/src/test/java/org/apache/ignite/cache/affinity/local/LocalAffinityFunctionTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/cache/affinity/local/LocalAffinityFunctionTest.java b/modules/core/src/test/java/org/apache/ignite/cache/affinity/local/LocalAffinityFunctionTest.java index 768c986..b447b78 100755 --- a/modules/core/src/test/java/org/apache/ignite/cache/affinity/local/LocalAffinityFunctionTest.java +++ b/modules/core/src/test/java/org/apache/ignite/cache/affinity/local/LocalAffinityFunctionTest.java @@ -56,14 +56,12 @@ public class LocalAffinityFunctionTest extends GridCommonAbstractTest { return cfg; } - @Override - protected void beforeTestsStarted() throws Exception { + @Override protected void beforeTestsStarted() throws Exception { super.beforeTestsStarted(); startGrids(NODE_CNT); } - @Override - protected void afterTestsStopped() throws Exception { + @Override protected void afterTestsStopped() throws Exception { super.afterTestsStopped(); stopAllGrids(); } http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/core/src/test/java/org/apache/ignite/cache/store/GridCacheBalancingStoreSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/cache/store/GridCacheBalancingStoreSelfTest.java b/modules/core/src/test/java/org/apache/ignite/cache/store/GridCacheBalancingStoreSelfTest.java index 760f329..d1e33b6 100644 --- a/modules/core/src/test/java/org/apache/ignite/cache/store/GridCacheBalancingStoreSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/cache/store/GridCacheBalancingStoreSelfTest.java @@ -342,9 +342,7 @@ public class GridCacheBalancingStoreSelfTest extends GridCommonAbstractTest { cnts[i] = new AtomicInteger(); } - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override public Integer load(Integer key) { try { U.sleep(500); @@ -358,16 +356,12 @@ public class GridCacheBalancingStoreSelfTest extends GridCommonAbstractTest { return key; } - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override public void loadCache(IgniteBiInClosure<Integer, Integer> clo, @Nullable Object... args) { // No-op. } - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override public Map<Integer, Integer> loadAll(Iterable<? extends Integer> keys) { try { U.sleep(500); @@ -387,37 +381,27 @@ public class GridCacheBalancingStoreSelfTest extends GridCommonAbstractTest { return loaded; } - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override public void write(Cache.Entry<? extends Integer, ? extends Integer> entry) { // No-op. } - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override public void writeAll(Collection<Cache.Entry<? extends Integer, ? extends Integer>> entries) { // No-op. } - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override public void delete(Object key) { // No-op. } - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override public void deleteAll(Collection<?> keys) { // No-op. } - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override public void sessionEnd(boolean commit) { // No-op. } http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/core/src/test/java/org/apache/ignite/internal/ClusterNodeMetricsSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/ClusterNodeMetricsSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/ClusterNodeMetricsSelfTest.java index 26bd941..da2203d 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/ClusterNodeMetricsSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/ClusterNodeMetricsSelfTest.java @@ -341,8 +341,7 @@ public class ClusterNodeMetricsSelfTest extends GridCommonAbstractTest { final Ignite ignite1 = startGrid(1); GridTestUtils.waitForCondition(new GridAbsPredicate() { - @Override - public boolean apply() { + @Override public boolean apply() { return ignite0.cluster().nodes().size() == 2 && ignite1.cluster().nodes().size() == 2; } }, 3000L); http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/core/src/test/java/org/apache/ignite/internal/ComputeJobCancelWithServiceSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/ComputeJobCancelWithServiceSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/ComputeJobCancelWithServiceSelfTest.java index 9c3611c..6978ba2 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/ComputeJobCancelWithServiceSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/ComputeJobCancelWithServiceSelfTest.java @@ -117,8 +117,7 @@ public class ComputeJobCancelWithServiceSelfTest extends GridCommonAbstractTest @IgniteInstanceResource private Ignite ignite; - @Override - public Object execute() throws IgniteException { + @Override public Object execute() throws IgniteException { MyService svc = ignite.services().service("my-service"); while (!isCancelled()) { http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/core/src/test/java/org/apache/ignite/internal/IgniteComputeEmptyClusterGroupTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/IgniteComputeEmptyClusterGroupTest.java b/modules/core/src/test/java/org/apache/ignite/internal/IgniteComputeEmptyClusterGroupTest.java index 2c70b5b..8069e37 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/IgniteComputeEmptyClusterGroupTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/IgniteComputeEmptyClusterGroupTest.java @@ -102,8 +102,7 @@ public class IgniteComputeEmptyClusterGroupTest extends GridCommonAbstractTest { final IgniteCompute comp = ignite(0).compute(empty); GridTestUtils.assertThrows(log, new Callable<Void>() { - @Override - public Void call() throws Exception { + @Override public Void call() throws Exception { comp.affinityRun(DEFAULT_CACHE_NAME, 1, new FailRunnable()); return null; @@ -119,8 +118,7 @@ public class IgniteComputeEmptyClusterGroupTest extends GridCommonAbstractTest { }, ClusterGroupEmptyException.class, null); GridTestUtils.assertThrows(log, new Callable<Void>() { - @Override - public Void call() throws Exception { + @Override public Void call() throws Exception { comp.affinityCall(DEFAULT_CACHE_NAME, 1, new FailCallable()); return null; http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/core/src/test/java/org/apache/ignite/internal/MarshallerContextLockingSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/MarshallerContextLockingSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/MarshallerContextLockingSelfTest.java index 0496382..522b941 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/MarshallerContextLockingSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/MarshallerContextLockingSelfTest.java @@ -103,8 +103,7 @@ public class MarshallerContextLockingSelfTest extends GridCommonAbstractTest { // Wait for all pending tasks in closure processor to complete. for (int i = 0; i < THREADS; i++) { ctx.closure().runLocalSafe(new GridPlainRunnable() { - @Override - public void run() { + @Override public void run() { arrive.countDown(); try { http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/binary/GridCacheBinaryObjectsAbstractSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/binary/GridCacheBinaryObjectsAbstractSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/binary/GridCacheBinaryObjectsAbstractSelfTest.java index 6936da5..06d62e4 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/binary/GridCacheBinaryObjectsAbstractSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/binary/GridCacheBinaryObjectsAbstractSelfTest.java @@ -1232,8 +1232,7 @@ public abstract class GridCacheBinaryObjectsAbstractSelfTest extends GridCommonA * No-op entry processor. */ private static class ObjectEntryProcessor implements EntryProcessor<Integer, TestObject, Boolean> { - @Override - public Boolean process(MutableEntry<Integer, TestObject> entry, Object... args) throws EntryProcessorException { + @Override public Boolean process(MutableEntry<Integer, TestObject> entry, Object... args) throws EntryProcessorException { TestObject obj = entry.getValue(); entry.setValue(new TestObject(obj.val)); http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/IgniteCountDownLatchAbstractSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/IgniteCountDownLatchAbstractSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/IgniteCountDownLatchAbstractSelfTest.java index 6f3ec2d..5dd316e 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/IgniteCountDownLatchAbstractSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/IgniteCountDownLatchAbstractSelfTest.java @@ -536,8 +536,7 @@ public abstract class IgniteCountDownLatchAbstractSelfTest extends IgniteAtomics } /** {@inheritDoc} */ - @Override - public void run() { + @Override public void run() { IgniteCountDownLatch latch1 = createLatch1(); IgniteCountDownLatch latch2 = createLatch2(); http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/IgniteDataStructureUniqueNameTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/IgniteDataStructureUniqueNameTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/IgniteDataStructureUniqueNameTest.java index 21c7690..166bf88 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/IgniteDataStructureUniqueNameTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/IgniteDataStructureUniqueNameTest.java @@ -211,8 +211,7 @@ public class IgniteDataStructureUniqueNameTest extends IgniteCollectionAbstractT }, IgniteException.class, null); GridTestUtils.assertThrows(log, new Callable<Void>() { - @Override - public Void call() throws Exception { + @Override public Void call() throws Exception { ignite.queue(name, 0, null); return null; http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/IgniteCacheTxIteratorSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/IgniteCacheTxIteratorSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/IgniteCacheTxIteratorSelfTest.java index cdf996d..605f2a8 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/IgniteCacheTxIteratorSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/IgniteCacheTxIteratorSelfTest.java @@ -200,11 +200,8 @@ public class IgniteCacheTxIteratorSelfTest extends GridCommonAbstractTest { this.data = data; } - /** - * {@inheritDoc} - */ - @Override - public boolean equals(final Object o) { + /** {@inheritDoc} */ + @Override public boolean equals(final Object o) { if (this == o) return true; if (o == null || getClass() != o.getClass()) @@ -216,19 +213,13 @@ public class IgniteCacheTxIteratorSelfTest extends GridCommonAbstractTest { } - /** - * {@inheritDoc} - */ - @Override - public int hashCode() { + /** {@inheritDoc} */ + @Override public int hashCode() { return data != null ? data.hashCode() : 0; } - /** - * {@inheritDoc} - */ - @Override - public String toString() { + /** {@inheritDoc} */ + @Override public String toString() { return S.toString(TestClass.class, this); } } http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/GridCacheContinuousQueryReplicatedTxOneNodeTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/GridCacheContinuousQueryReplicatedTxOneNodeTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/GridCacheContinuousQueryReplicatedTxOneNodeTest.java index cdd17e6..6474df5 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/GridCacheContinuousQueryReplicatedTxOneNodeTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/GridCacheContinuousQueryReplicatedTxOneNodeTest.java @@ -122,8 +122,7 @@ public class GridCacheContinuousQueryReplicatedTxOneNodeTest extends GridCommonA final CountDownLatch latch = new CountDownLatch(10); qry.setLocalListener(new CacheEntryUpdatedListener<String, Integer>() { - @Override - public void onUpdated(Iterable<CacheEntryEvent<? extends String, ? extends Integer>> evts) + @Override public void onUpdated(Iterable<CacheEntryEvent<? extends String, ? extends Integer>> evts) throws CacheEntryListenerException { for (CacheEntryEvent<? extends String, ? extends Integer> evt : evts) { cnt.incrementAndGet(); http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/store/GridCacheWriteBehindStoreMultithreadedSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/store/GridCacheWriteBehindStoreMultithreadedSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/store/GridCacheWriteBehindStoreMultithreadedSelfTest.java index 15c58d9..4fce452 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/store/GridCacheWriteBehindStoreMultithreadedSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/store/GridCacheWriteBehindStoreMultithreadedSelfTest.java @@ -113,8 +113,7 @@ public class GridCacheWriteBehindStoreMultithreadedSelfTest extends GridCacheWri try { Thread timer = new Thread(new Runnable() { - @Override - public void run() { + @Override public void run() { try { U.sleep(FLUSH_FREQUENCY+50); } catch (IgniteInterruptedCheckedException e) { http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/core/src/test/java/org/apache/ignite/internal/processors/compute/IgniteComputeConfigVariationsFullApiTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/compute/IgniteComputeConfigVariationsFullApiTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/compute/IgniteComputeConfigVariationsFullApiTest.java index 231fc9e..d1fbb34 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/compute/IgniteComputeConfigVariationsFullApiTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/compute/IgniteComputeConfigVariationsFullApiTest.java @@ -1324,18 +1324,14 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat eVal = val; } - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override public void writeExternal(ObjectOutput out) throws IOException { out.writeObject(argument(0)); JobUtils.writeJobState(out, isVal, bVal, cVal, sVal, intVal, lVal, fltVal, dblVal, strVal, arrVal, eVal); } - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException { setArguments(in.readObject()); @@ -1352,9 +1348,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat eVal = (TestJobEnum)in.readObject(); } - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override protected void checkState() { JobUtils.checkJobState(isVal, bVal, cVal, sVal, intVal, lVal, fltVal, dblVal, strVal, arrVal, eVal); } @@ -1434,18 +1428,14 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat eVal = val; } - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override public void writeBinary(BinaryWriter writer) throws BinaryObjectException { writer.writeObject("arg", argument(0)); JobUtils.writeJobState(writer, isVal, bVal, cVal, sVal, intVal, lVal, fltVal, dblVal, strVal, arrVal, eVal); } - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override public void readBinary(BinaryReader reader) throws BinaryObjectException { Object arg = reader.readObject("arg"); @@ -1464,9 +1454,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat eVal = reader.readEnum("eVal"); } - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override protected void checkState() { JobUtils.checkJobState(isVal, bVal, cVal, sVal, intVal, lVal, fltVal, dblVal, strVal, arrVal, eVal); } @@ -1655,9 +1643,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat eVal = (TestJobEnum)in.readObject(); } - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override protected void checkState() { JobUtils.checkJobState(isVal, bVal, cVal, sVal, intVal, lVal, fltVal, dblVal, strVal, arrVal, eVal); } @@ -1750,9 +1736,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat eVal = reader.readEnum("eVal"); } - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override protected void checkState() { JobUtils.checkJobState(isVal, bVal, cVal, sVal, intVal, lVal, fltVal, dblVal, strVal, arrVal, eVal); } @@ -1931,18 +1915,14 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat eVal = val; } - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override public void writeExternal(ObjectOutput out) throws IOException { out.writeObject(arg); JobUtils.writeJobState(out, isVal, bVal, cVal, sVal, intVal, lVal, fltVal, dblVal, strVal, arrVal, eVal); } - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException { arg = in.readObject(); @@ -1959,9 +1939,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat eVal = (TestJobEnum)in.readObject(); } - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override protected void checkState() { JobUtils.checkJobState(isVal, bVal, cVal, sVal, intVal, lVal, fltVal, dblVal, strVal, arrVal, eVal); } @@ -2041,18 +2019,14 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat eVal = val; } - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override public void writeBinary(BinaryWriter writer) throws BinaryObjectException { writer.writeObject("arg", arg); JobUtils.writeJobState(writer, isVal, bVal, cVal, sVal, intVal, lVal, fltVal, dblVal, strVal, arrVal, eVal); } - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override public void readBinary(BinaryReader reader) throws BinaryObjectException { arg = reader.readObject("arg"); @@ -2069,9 +2043,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat eVal = reader.readEnum("eVal"); } - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override protected void checkState() { JobUtils.checkJobState(isVal, bVal, cVal, sVal, intVal, lVal, fltVal, dblVal, strVal, arrVal, eVal); } @@ -2150,9 +2122,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat eVal = val; } - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override public void run() { checkState(); } @@ -2238,16 +2208,12 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat eVal = val; } - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override public void writeExternal(ObjectOutput out) throws IOException { JobUtils.writeJobState(out, isVal, bVal, cVal, sVal, intVal, lVal, fltVal, dblVal, strVal, arrVal, eVal); } - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException { isVal = in.readBoolean(); bVal = in.readByte(); @@ -2262,9 +2228,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat eVal = (TestJobEnum)in.readObject(); } - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override protected void checkState() { JobUtils.checkJobState(isVal, bVal, cVal, sVal, intVal, lVal, fltVal, dblVal, strVal, arrVal, eVal); } @@ -2343,16 +2307,12 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat eVal = val; } - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override public void writeBinary(BinaryWriter writer) throws BinaryObjectException { JobUtils.writeJobState(writer, isVal, bVal, cVal, sVal, intVal, lVal, fltVal, dblVal, strVal, arrVal, eVal); } - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override public void readBinary(BinaryReader reader) throws BinaryObjectException { isVal = reader.readBoolean("isVal"); bVal = reader.readByte("bVal"); @@ -2367,9 +2327,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat eVal = reader.readEnum("eVal"); } - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override protected void checkState() { JobUtils.checkJobState(isVal, bVal, cVal, sVal, intVal, lVal, fltVal, dblVal, strVal, arrVal, eVal); } http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsSecondaryFileSystemInjectionSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsSecondaryFileSystemInjectionSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsSecondaryFileSystemInjectionSelfTest.java index e17c2df..1e24610 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsSecondaryFileSystemInjectionSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsSecondaryFileSystemInjectionSelfTest.java @@ -214,8 +214,7 @@ public class IgfsSecondaryFileSystemInjectionSelfTest extends GridCommonAbstract } /** {@inheritDoc} */ - @Override - public IgfsSecondaryFileSystemPositionedReadable open(IgfsPath path, int bufSize) throws IgniteException { + @Override public IgfsSecondaryFileSystemPositionedReadable open(IgfsPath path, int bufSize) throws IgniteException { return null; } @@ -225,8 +224,7 @@ public class IgfsSecondaryFileSystemInjectionSelfTest extends GridCommonAbstract } /** {@inheritDoc} */ - @Override - public OutputStream create(IgfsPath path, int bufSize, boolean overwrite, int replication, long blockSize, + @Override public OutputStream create(IgfsPath path, int bufSize, boolean overwrite, int replication, long blockSize, @Nullable Map<String, String> props) throws IgniteException { return null; } http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/core/src/test/java/org/apache/ignite/internal/processors/service/GridServiceProcessorAbstractSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/service/GridServiceProcessorAbstractSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/service/GridServiceProcessorAbstractSelfTest.java index db07cde..9affe85 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/service/GridServiceProcessorAbstractSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/service/GridServiceProcessorAbstractSelfTest.java @@ -303,8 +303,7 @@ public abstract class GridServiceProcessorAbstractSelfTest extends GridCommonAbs g.services().deployMultiple(name, new DummyService(), nodeCount() * 2, 3); GridTestUtils.retryAssert(log, 50, 200, new CA() { - @Override - public void apply() { + @Override public void apply() { int cnt = 0; for (int i = 0; i < nodeCount(); i++) { http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/core/src/test/java/org/apache/ignite/internal/util/io/GridUnsafeDataOutputArraySizingSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/util/io/GridUnsafeDataOutputArraySizingSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/util/io/GridUnsafeDataOutputArraySizingSelfTest.java index 4108779..7e59a6a 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/util/io/GridUnsafeDataOutputArraySizingSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/util/io/GridUnsafeDataOutputArraySizingSelfTest.java @@ -132,9 +132,7 @@ public class GridUnsafeDataOutputArraySizingSelfTest extends GridCommonAbstractT this.len = len; } - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override public boolean apply() { try { out.write(bytes); http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/core/src/test/java/org/apache/ignite/internal/util/ipc/shmem/benchmark/IpcSharedMemoryBenchmarkReader.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/util/ipc/shmem/benchmark/IpcSharedMemoryBenchmarkReader.java b/modules/core/src/test/java/org/apache/ignite/internal/util/ipc/shmem/benchmark/IpcSharedMemoryBenchmarkReader.java index d86f127..7275454 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/util/ipc/shmem/benchmark/IpcSharedMemoryBenchmarkReader.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/util/ipc/shmem/benchmark/IpcSharedMemoryBenchmarkReader.java @@ -85,8 +85,7 @@ public class IpcSharedMemoryBenchmarkReader implements IpcSharedMemoryBenchmarkP final IpcEndpoint endPnt = srv.accept(); new Thread(new Runnable() { - @Override - public void run() { + @Override public void run() { InputStream space = null; try { http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/core/src/test/java/org/apache/ignite/internal/util/offheap/GridOffHeapMapAbstractSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/util/offheap/GridOffHeapMapAbstractSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/util/offheap/GridOffHeapMapAbstractSelfTest.java index 4cda0c2..ac6e531 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/util/offheap/GridOffHeapMapAbstractSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/util/offheap/GridOffHeapMapAbstractSelfTest.java @@ -763,8 +763,7 @@ public abstract class GridOffHeapMapAbstractSelfTest extends GridCommonAbstractT } IgniteInternalFuture<?> fut = multithreadedAsync(new Callable<Void>() { - @Override - public Void call() throws IgniteCheckedException { + @Override public Void call() throws IgniteCheckedException { Random rnd = new Random(); while (!stop.get()) { http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/core/src/test/java/org/apache/ignite/internal/util/offheap/unsafe/GridUnsafeMemorySelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/util/offheap/unsafe/GridUnsafeMemorySelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/util/offheap/unsafe/GridUnsafeMemorySelfTest.java index 1452253..ff278b2 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/util/offheap/unsafe/GridUnsafeMemorySelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/util/offheap/unsafe/GridUnsafeMemorySelfTest.java @@ -275,8 +275,7 @@ public class GridUnsafeMemorySelfTest extends GridCommonAbstractTest { guard.begin(); guard.finalizeLater(new Runnable() { - @Override - public void run() { + @Override public void run() { i.incrementAndGet(); } }); http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/core/src/test/java/org/apache/ignite/marshaller/GridMarshallerAbstractTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/marshaller/GridMarshallerAbstractTest.java b/modules/core/src/test/java/org/apache/ignite/marshaller/GridMarshallerAbstractTest.java index 6e98eea..66f0d72 100644 --- a/modules/core/src/test/java/org/apache/ignite/marshaller/GridMarshallerAbstractTest.java +++ b/modules/core/src/test/java/org/apache/ignite/marshaller/GridMarshallerAbstractTest.java @@ -481,8 +481,7 @@ public abstract class GridMarshallerAbstractTest extends GridCommonAbstractTest final Ignite ignite = grid(); GridMarshallerTestBean inBean = newTestBean(ignite.cluster().forPredicate(new IgnitePredicate<ClusterNode>() { - @Override - public boolean apply(ClusterNode n) { + @Override public boolean apply(ClusterNode n) { return n.id().equals(ignite.cluster().localNode().id()); } })); @@ -661,8 +660,7 @@ public abstract class GridMarshallerAbstractTest extends GridCommonAbstractTest IgniteCompute compute = compute(grid().cluster().forNode(g1.cluster().localNode())); compute.run(new IgniteRunnable() { - @Override - public void run() { + @Override public void run() { // No-op. } }); http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/core/src/test/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpiFaultyClientTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpiFaultyClientTest.java b/modules/core/src/test/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpiFaultyClientTest.java index 0015701..ad565c8 100644 --- a/modules/core/src/test/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpiFaultyClientTest.java +++ b/modules/core/src/test/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpiFaultyClientTest.java @@ -142,8 +142,7 @@ public class TcpCommunicationSpiFaultyClientTest extends GridCommonAbstractTest final CountDownLatch latch = new CountDownLatch(1); grid(0).events().localListen(new IgnitePredicate<Event>() { - @Override - public boolean apply(Event event) { + @Override public boolean apply(Event event) { latch.countDown(); return true; http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/extdata/p2p/src/main/java/org/apache/ignite/tests/p2p/P2PTestTaskExternalPath2.java ---------------------------------------------------------------------- diff --git a/modules/extdata/p2p/src/main/java/org/apache/ignite/tests/p2p/P2PTestTaskExternalPath2.java b/modules/extdata/p2p/src/main/java/org/apache/ignite/tests/p2p/P2PTestTaskExternalPath2.java index 971ec65..3737402 100644 --- a/modules/extdata/p2p/src/main/java/org/apache/ignite/tests/p2p/P2PTestTaskExternalPath2.java +++ b/modules/extdata/p2p/src/main/java/org/apache/ignite/tests/p2p/P2PTestTaskExternalPath2.java @@ -127,9 +127,7 @@ public class P2PTestTaskExternalPath2 extends ComputeTaskAdapter<Object, Integer this.sleep = sleep; } - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override public Integer execute() { assert ignite.configuration().getNodeId().equals(argument(0)); http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/flink/src/test/java/org/apache/ignite/sink/flink/FlinkIgniteSinkSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/flink/src/test/java/org/apache/ignite/sink/flink/FlinkIgniteSinkSelfTest.java b/modules/flink/src/test/java/org/apache/ignite/sink/flink/FlinkIgniteSinkSelfTest.java index 93851ca..083457c 100644 --- a/modules/flink/src/test/java/org/apache/ignite/sink/flink/FlinkIgniteSinkSelfTest.java +++ b/modules/flink/src/test/java/org/apache/ignite/sink/flink/FlinkIgniteSinkSelfTest.java @@ -97,8 +97,7 @@ public class FlinkIgniteSinkSelfTest extends GridCommonAbstractTest { private boolean running = true; - @Override - public void run(SourceContext<Map> ctx) throws Exception { + @Override public void run(SourceContext<Map> ctx) throws Exception { Map testDataMap = new HashMap<>(); long cnt = 0; @@ -110,8 +109,7 @@ public class FlinkIgniteSinkSelfTest extends GridCommonAbstractTest { ctx.collect(testDataMap); } - @Override - public void cancel() { + @Override public void cancel() { running = false; } }).setParallelism(1); @@ -178,8 +176,7 @@ public class FlinkIgniteSinkSelfTest extends GridCommonAbstractTest { * @param evt Cache Event. * @return {@code true}. */ - @Override - public boolean apply(CacheEvent evt) { + @Override public boolean apply(CacheEvent evt) { latch.countDown(); return true; http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/impl/igfs/HadoopIgfs20FileSystemAbstractSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/impl/igfs/HadoopIgfs20FileSystemAbstractSelfTest.java b/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/impl/igfs/HadoopIgfs20FileSystemAbstractSelfTest.java index 016fadf..3b0553f 100644 --- a/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/impl/igfs/HadoopIgfs20FileSystemAbstractSelfTest.java +++ b/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/impl/igfs/HadoopIgfs20FileSystemAbstractSelfTest.java @@ -775,8 +775,7 @@ public abstract class HadoopIgfs20FileSystemAbstractSelfTest extends IgfsCommonA os.close(); GridTestUtils.assertThrows(log, new Callable<Object>() { - @Override - public Object call() throws Exception { + @Override public Object call() throws Exception { fs.setOwner(file, "aUser", null); return null; http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/impl/igfs/IgniteHadoopFileSystemAbstractSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/impl/igfs/IgniteHadoopFileSystemAbstractSelfTest.java b/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/impl/igfs/IgniteHadoopFileSystemAbstractSelfTest.java index 2214b5b..5ae2c3e 100644 --- a/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/impl/igfs/IgniteHadoopFileSystemAbstractSelfTest.java +++ b/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/impl/igfs/IgniteHadoopFileSystemAbstractSelfTest.java @@ -962,8 +962,7 @@ public abstract class IgniteHadoopFileSystemAbstractSelfTest extends IgfsCommonA os.close(); GridTestUtils.assertThrows(log, new Callable<Object>() { - @Override - public Object call() throws Exception { + @Override public Object call() throws Exception { fs.setOwner(file, "aUser", null); return null; @@ -1166,8 +1165,7 @@ public abstract class IgniteHadoopFileSystemAbstractSelfTest extends IgfsCommonA FSDataOutputStream appendOs = fs.append(file); GridTestUtils.assertThrows(log, new Callable<Object>() { - @Override - public Object call() throws Exception { + @Override public Object call() throws Exception { return fs.append(file); } }, IOException.class, null); http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/impl/taskexecutor/HadoopExecutorServiceTest.java ---------------------------------------------------------------------- diff --git a/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/impl/taskexecutor/HadoopExecutorServiceTest.java b/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/impl/taskexecutor/HadoopExecutorServiceTest.java index b4e63d1..845afae 100644 --- a/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/impl/taskexecutor/HadoopExecutorServiceTest.java +++ b/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/impl/taskexecutor/HadoopExecutorServiceTest.java @@ -45,8 +45,7 @@ public class HadoopExecutorServiceTest extends GridCommonAbstractTest { @Override public Object call() throws Exception { for (int i = 0; i < loops; i++) { exec.submit(new Callable<Void>() { - @Override - public Void call() throws Exception { + @Override public Void call() throws Exception { sum.increment(); return null; http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheQueryIndexDisabledSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheQueryIndexDisabledSelfTest.java b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheQueryIndexDisabledSelfTest.java index e2e5fd6..525b688 100644 --- a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheQueryIndexDisabledSelfTest.java +++ b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheQueryIndexDisabledSelfTest.java @@ -251,9 +251,7 @@ public class GridCacheQueryIndexDisabledSelfTest extends GridCommonAbstractTest return val; } - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override public String toString() { return S.toString(SqlValue.class, this); } http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/IgniteCacheDistributedPartitionQueryNodeRestartsSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/IgniteCacheDistributedPartitionQueryNodeRestartsSelfTest.java b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/IgniteCacheDistributedPartitionQueryNodeRestartsSelfTest.java index 68f9842..8525410 100644 --- a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/IgniteCacheDistributedPartitionQueryNodeRestartsSelfTest.java +++ b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/IgniteCacheDistributedPartitionQueryNodeRestartsSelfTest.java @@ -45,8 +45,7 @@ public class IgniteCacheDistributedPartitionQueryNodeRestartsSelfTest final AtomicInteger cnt = new AtomicInteger(); IgniteInternalFuture<?> fut = multithreadedAsync(new Runnable() { - @Override - public void run() { + @Override public void run() { while (!stop.get()) { doTestJoinQuery(client, rnd.nextInt(PARTS_PER_REGION.length) + 1); @@ -61,8 +60,7 @@ public class IgniteCacheDistributedPartitionQueryNodeRestartsSelfTest final AtomicIntegerArray restartStats = new AtomicIntegerArray(GRIDS_COUNT); IgniteInternalFuture<?> fut2 = multithreadedAsync(new Callable<Void>() { - @Override - public Void call() throws Exception { + @Override public Void call() throws Exception { while (!stop.get()) { int grid = rnd.nextInt(GRIDS_COUNT); http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/kafka/src/test/java/org/apache/ignite/stream/kafka/connect/IgniteSinkConnectorTest.java ---------------------------------------------------------------------- diff --git a/modules/kafka/src/test/java/org/apache/ignite/stream/kafka/connect/IgniteSinkConnectorTest.java b/modules/kafka/src/test/java/org/apache/ignite/stream/kafka/connect/IgniteSinkConnectorTest.java index 440a7d5..912ea87 100644 --- a/modules/kafka/src/test/java/org/apache/ignite/stream/kafka/connect/IgniteSinkConnectorTest.java +++ b/modules/kafka/src/test/java/org/apache/ignite/stream/kafka/connect/IgniteSinkConnectorTest.java @@ -161,8 +161,7 @@ public class IgniteSinkConnectorTest extends GridCommonAbstractTest { */ private void testSinkPuts(Map<String, String> sinkProps, boolean keyless) throws Exception { FutureCallback<Herder.Created<ConnectorInfo>> cb = new FutureCallback<>(new Callback<Herder.Created<ConnectorInfo>>() { - @Override - public void onCompletion(Throwable error, Herder.Created<ConnectorInfo> info) { + @Override public void onCompletion(Throwable error, Herder.Created<ConnectorInfo> info) { if (error != null) throw new RuntimeException("Failed to create a job!"); } http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/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 f47450f..1609e9c 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 @@ -164,8 +164,7 @@ public class IgniteSourceConnectorTest extends GridCommonAbstractTest { */ private void doTest(Map<String, String> srcProps, boolean conditioned) throws Exception { FutureCallback<Herder.Created<ConnectorInfo>> cb = new FutureCallback<>(new Callback<Herder.Created<ConnectorInfo>>() { - @Override - public void onCompletion(Throwable error, Herder.Created<ConnectorInfo> info) { + @Override public void onCompletion(Throwable error, Herder.Created<ConnectorInfo> info) { if (error != null) throw new RuntimeException("Failed to create a job!", error); } http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/log4j2/src/test/java/org/apache/ignite/logger/log4j2/GridLog4j2InitializedTest.java ---------------------------------------------------------------------- diff --git a/modules/log4j2/src/test/java/org/apache/ignite/logger/log4j2/GridLog4j2InitializedTest.java b/modules/log4j2/src/test/java/org/apache/ignite/logger/log4j2/GridLog4j2InitializedTest.java index f04c28c..4758e0a 100644 --- a/modules/log4j2/src/test/java/org/apache/ignite/logger/log4j2/GridLog4j2InitializedTest.java +++ b/modules/log4j2/src/test/java/org/apache/ignite/logger/log4j2/GridLog4j2InitializedTest.java @@ -35,8 +35,7 @@ public class GridLog4j2InitializedTest extends TestCase { /** * @throws Exception If failed. */ - @Override - protected void setUp() throws Exception { + @Override protected void setUp() throws Exception { } http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/log4j2/src/test/java/org/apache/ignite/logger/log4j2/GridLog4j2LoggingFileTest.java ---------------------------------------------------------------------- diff --git a/modules/log4j2/src/test/java/org/apache/ignite/logger/log4j2/GridLog4j2LoggingFileTest.java b/modules/log4j2/src/test/java/org/apache/ignite/logger/log4j2/GridLog4j2LoggingFileTest.java index f2c8546..5c19de0 100644 --- a/modules/log4j2/src/test/java/org/apache/ignite/logger/log4j2/GridLog4j2LoggingFileTest.java +++ b/modules/log4j2/src/test/java/org/apache/ignite/logger/log4j2/GridLog4j2LoggingFileTest.java @@ -33,8 +33,7 @@ public class GridLog4j2LoggingFileTest extends TestCase { private IgniteLogger log; /** {@inheritDoc} */ - @Override - protected void setUp() throws Exception { + @Override protected void setUp() throws Exception { File xml = GridTestUtils http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/mesos/src/main/java/org/apache/ignite/mesos/IgniteTask.java ---------------------------------------------------------------------- diff --git a/modules/mesos/src/main/java/org/apache/ignite/mesos/IgniteTask.java b/modules/mesos/src/main/java/org/apache/ignite/mesos/IgniteTask.java index 1e56eab..a4e3e25 100644 --- a/modules/mesos/src/main/java/org/apache/ignite/mesos/IgniteTask.java +++ b/modules/mesos/src/main/java/org/apache/ignite/mesos/IgniteTask.java @@ -76,8 +76,7 @@ public class IgniteTask { return disk; } - @Override - public String toString() { + @Override public String toString() { return "IgniteTask " + "host: [" + host + ']' + ", cpuCores: [" + cpuCores + "]" + http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/spring/src/main/java/org/apache/ignite/transactions/spring/SpringTransactionManager.java ---------------------------------------------------------------------- diff --git a/modules/spring/src/main/java/org/apache/ignite/transactions/spring/SpringTransactionManager.java b/modules/spring/src/main/java/org/apache/ignite/transactions/spring/SpringTransactionManager.java index d69ca5b..2fe8aad 100644 --- a/modules/spring/src/main/java/org/apache/ignite/transactions/spring/SpringTransactionManager.java +++ b/modules/spring/src/main/java/org/apache/ignite/transactions/spring/SpringTransactionManager.java @@ -338,9 +338,7 @@ public class SpringTransactionManager extends AbstractPlatformTransactionManager this.igniteInstanceName = igniteInstanceName; } - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override public void afterPropertiesSet() throws Exception { assert ignite == null; @@ -364,9 +362,7 @@ public class SpringTransactionManager extends AbstractPlatformTransactionManager log = ignite.log(); } - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override protected Object doGetTransaction() throws TransactionException { IgniteTransactionObject txObj = new IgniteTransactionObject(); @@ -376,9 +372,7 @@ public class SpringTransactionManager extends AbstractPlatformTransactionManager return txObj; } - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override protected void doBegin(Object transaction, TransactionDefinition definition) throws TransactionException { if (definition.getIsolationLevel() == TransactionDefinition.ISOLATION_READ_UNCOMMITTED) throw new InvalidIsolationLevelException("Ignite does not support READ_UNCOMMITTED isolation level."); @@ -419,9 +413,7 @@ public class SpringTransactionManager extends AbstractPlatformTransactionManager } } - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override protected void doCommit(DefaultTransactionStatus status) throws TransactionException { IgniteTransactionObject txObj = (IgniteTransactionObject)status.getTransaction(); Transaction tx = txObj.getTransactionHolder().getTransaction(); @@ -437,9 +429,7 @@ public class SpringTransactionManager extends AbstractPlatformTransactionManager } } - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override protected void doRollback(DefaultTransactionStatus status) throws TransactionException { IgniteTransactionObject txObj = (IgniteTransactionObject)status.getTransaction(); Transaction tx = txObj.getTransactionHolder().getTransaction(); @@ -455,9 +445,7 @@ public class SpringTransactionManager extends AbstractPlatformTransactionManager } } - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override protected void doCleanupAfterCompletion(Object transaction) { IgniteTransactionObject txObj = (IgniteTransactionObject)transaction; @@ -473,18 +461,14 @@ public class SpringTransactionManager extends AbstractPlatformTransactionManager txObj.getTransactionHolder().clear(); } - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override protected boolean isExistingTransaction(Object transaction) throws TransactionException { IgniteTransactionObject txObj = (IgniteTransactionObject)transaction; return (txObj.getTransactionHolder() != null && txObj.getTransactionHolder().isTransactionActive()); } - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override public Object getResourceFactory() { return this.ignite; } http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/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 6dad1f4..45655e1 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 @@ -66,9 +66,7 @@ public class IgniteDynamicCacheConfigTest extends GridCommonAbstractTest { stopAllGrids(); } - /** - * {@inheritDoc} - */ + /** {@inheritDoc} */ @Override protected IgniteConfiguration getConfiguration(String igniteInstanceName) throws Exception { IgniteConfiguration cfg = super.getConfiguration(igniteInstanceName); http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/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 3014706..8640c0b 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 @@ -43,11 +43,8 @@ public class GridSpringTransactionManagerSelfTest extends GridCommonAbstractTest /** */ private GridSpringTransactionService service; - /** - * {@inheritDoc} - */ - @Override - protected IgniteConfiguration getConfiguration(String igniteInstanceName) throws Exception { + /** {@inheritDoc} */ + @Override protected IgniteConfiguration getConfiguration(String igniteInstanceName) throws Exception { IgniteConfiguration cfg = super.getConfiguration(igniteInstanceName); CacheConfiguration cache = new CacheConfiguration(DEFAULT_CACHE_NAME); @@ -66,45 +63,30 @@ public class GridSpringTransactionManagerSelfTest extends GridCommonAbstractTest return cfg; } - /** - * {@inheritDoc} - */ - @Override - public String getTestIgniteInstanceName() { + /** {@inheritDoc} */ + @Override public String getTestIgniteInstanceName() { return "testGrid"; } - /** - * {@inheritDoc} - */ - @Override - protected void beforeTestsStarted() throws Exception { + /** {@inheritDoc} */ + @Override protected void beforeTestsStarted() throws Exception { startGrid(); } - /** - * {@inheritDoc} - */ - @Override - protected void afterTestsStopped() throws Exception { + /** {@inheritDoc} */ + @Override protected void afterTestsStopped() throws Exception { stopAllGrids(); } - /** - * {@inheritDoc} - */ - @Override - protected void beforeTest() throws Exception { + /** {@inheritDoc} */ + @Override protected void beforeTest() throws Exception { ApplicationContext applicationContext = new GenericXmlApplicationContext("config/spring-transactions.xml"); service = (GridSpringTransactionService)applicationContext.getBean("gridSpringTransactionService"); } - /** - * {@inheritDoc} - */ - @Override - protected void afterTest() throws Exception { + /** {@inheritDoc} */ + @Override protected void afterTest() throws Exception { grid().cache(CACHE_NAME).removeAll(); } http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/urideploy/src/main/java/org/apache/ignite/spi/deployment/uri/UriDeploymentSpi.java ---------------------------------------------------------------------- diff --git a/modules/urideploy/src/main/java/org/apache/ignite/spi/deployment/uri/UriDeploymentSpi.java b/modules/urideploy/src/main/java/org/apache/ignite/spi/deployment/uri/UriDeploymentSpi.java index b49e2c5..68ed0d9 100644 --- a/modules/urideploy/src/main/java/org/apache/ignite/spi/deployment/uri/UriDeploymentSpi.java +++ b/modules/urideploy/src/main/java/org/apache/ignite/spi/deployment/uri/UriDeploymentSpi.java @@ -701,8 +701,7 @@ public class UriDeploymentSpi extends IgniteSpiAdapter implements DeploymentSpi } /** {@inheritDoc} */ - @Nullable - @Override public DeploymentResource findResource(String rsrcName) { + @Nullable @Override public DeploymentResource findResource(String rsrcName) { assert rsrcName != null; // Wait until all scanner managers finish their first scanning. @@ -845,8 +844,7 @@ public class UriDeploymentSpi extends IgniteSpiAdapter implements DeploymentSpi * if registered resources conflicts with rule when all task classes must be * annotated with different task names. */ - @Nullable - private Map<String, String> addResources(ClassLoader ldr, GridUriDeploymentUnitDescriptor desc, Class<?>[] clss) + @Nullable private Map<String, String> addResources(ClassLoader ldr, GridUriDeploymentUnitDescriptor desc, Class<?>[] clss) throws IgniteSpiException { assert ldr != null; assert desc != null; http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/urideploy/src/main/java/org/apache/ignite/spi/deployment/uri/scanners/http/UriDeploymentHttpScanner.java ---------------------------------------------------------------------- diff --git a/modules/urideploy/src/main/java/org/apache/ignite/spi/deployment/uri/scanners/http/UriDeploymentHttpScanner.java b/modules/urideploy/src/main/java/org/apache/ignite/spi/deployment/uri/scanners/http/UriDeploymentHttpScanner.java index bb7260d..7fe3602 100644 --- a/modules/urideploy/src/main/java/org/apache/ignite/spi/deployment/uri/scanners/http/UriDeploymentHttpScanner.java +++ b/modules/urideploy/src/main/java/org/apache/ignite/spi/deployment/uri/scanners/http/UriDeploymentHttpScanner.java @@ -157,8 +157,7 @@ public class UriDeploymentHttpScanner implements UriDeploymentScanner { return new TrustManager[]{ new X509TrustManager() { /** {@inheritDoc} */ - @Nullable - @Override public X509Certificate[] getAcceptedIssuers() { return null; } + @Nullable @Override public X509Certificate[] getAcceptedIssuers() { return null; } /** {@inheritDoc} */ @Override public void checkClientTrusted(X509Certificate[] certs, String authType) { http://git-wip-us.apache.org/repos/asf/ignite/blob/794e1d36/modules/urideploy/src/test/java/org/apache/ignite/spi/deployment/uri/GridUriDeploymentMd5CheckSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/urideploy/src/test/java/org/apache/ignite/spi/deployment/uri/GridUriDeploymentMd5CheckSelfTest.java b/modules/urideploy/src/test/java/org/apache/ignite/spi/deployment/uri/GridUriDeploymentMd5CheckSelfTest.java index ac27305..923b93b 100644 --- a/modules/urideploy/src/test/java/org/apache/ignite/spi/deployment/uri/GridUriDeploymentMd5CheckSelfTest.java +++ b/modules/urideploy/src/test/java/org/apache/ignite/spi/deployment/uri/GridUriDeploymentMd5CheckSelfTest.java @@ -179,11 +179,9 @@ public class GridUriDeploymentMd5CheckSelfTest extends GridUriDeploymentAbstract * * @throws Exception if failed. */ - @Override - protected void beforeTestsStarted() throws Exception { + @Override protected void beforeTestsStarted() throws Exception { getSpi().setListener(new DeploymentListener() { - @Override - public void onUnregistered(ClassLoader ldr) { + @Override public void onUnregistered(ClassLoader ldr) { undeployCntr.incrementAndGet(); } }); @@ -194,8 +192,7 @@ public class GridUriDeploymentMd5CheckSelfTest extends GridUriDeploymentAbstract * * @throws Exception if cleanup failed. */ - @Override - protected void afterTestsStopped() throws Exception { + @Override protected void afterTestsStopped() throws Exception { U.delete(getDeployDir()); } } \ No newline at end of file
