diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java index 8e17cb165713a..8ef4853842e89 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java @@ -1177,8 +1177,7 @@ private void send( boolean ordered, long timeout, boolean skipOnTimeout - ) - throws IgniteCheckedException { + ) throws IgniteCheckedException { assert nodes != null; assert topic != null; assert msg != null; diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemandPool.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemandPool.java index 5011e353da871..9c7652c987f58 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemandPool.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemandPool.java @@ -569,6 +569,8 @@ public Object topic(long idx) { */ private Set demandFromNode(ClusterNode node, final long topVer, GridDhtPartitionDemandMessage d, GridDhtPartitionsExchangeFuture exchFut) throws InterruptedException, IgniteCheckedException { + GridDhtPartitionTopology top = cctx.dht().topology(); + cntr++; d.topic(topic(cntr)); @@ -690,7 +692,7 @@ private Set demandFromNode(ClusterNode node, final long topVer, GridDht int p = e.getKey(); if (cctx.affinity().localNode(p, topVer)) { - GridDhtLocalPartition part = cctx.dht().topology().localPartition(p, topVer, true); + GridDhtLocalPartition part = top.localPartition(p, topVer, true); assert part != null; @@ -734,7 +736,7 @@ private Set demandFromNode(ClusterNode node, final long topVer, GridDht if (last) { remaining.remove(p); - cctx.dht().topology().own(part); + top.own(part); if (log.isDebugEnabled()) log.debug("Finished preloading partition: " + part); diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskProcessor.java index 2ecb4b4775fc1..9a36a5bff0d66 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskProcessor.java @@ -60,7 +60,7 @@ public class GridTaskProcessor extends GridProcessorAdapter { private final IgniteMarshaller marsh; /** */ - public final ConcurrentMap> tasks = GridConcurrentFactory.newMap(); + private final ConcurrentMap> tasks = GridConcurrentFactory.newMap(); /** */ private boolean stopping; diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskWorker.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskWorker.java index a921346a8044a..0631a8e5b4145 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskWorker.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskWorker.java @@ -27,7 +27,6 @@ import org.apache.ignite.marshaller.*; import org.apache.ignite.resources.*; import org.apache.ignite.internal.managers.deployment.*; -import org.apache.ignite.internal.processors.job.*; import org.apache.ignite.internal.processors.timeout.*; import org.apache.ignite.internal.util.typedef.*; import org.apache.ignite.internal.util.typedef.internal.*;