FInalization.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/d8239c07 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/d8239c07 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/d8239c07 Branch: refs/heads/ignite-3414 Commit: d8239c071ec3d000f027b63cc3000d2335497ec6 Parents: fc58697 Author: vozerov-gridgain <[email protected]> Authored: Tue Jul 19 10:05:53 2016 +0300 Committer: vozerov-gridgain <[email protected]> Committed: Tue Jul 19 10:05:53 2016 +0300 ---------------------------------------------------------------------- .../hadoop/mapreduce/IgniteHadoopWeightedMapReducePlanner.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/d8239c07/modules/hadoop/src/main/java/org/apache/ignite/hadoop/mapreduce/IgniteHadoopWeightedMapReducePlanner.java ---------------------------------------------------------------------- diff --git a/modules/hadoop/src/main/java/org/apache/ignite/hadoop/mapreduce/IgniteHadoopWeightedMapReducePlanner.java b/modules/hadoop/src/main/java/org/apache/ignite/hadoop/mapreduce/IgniteHadoopWeightedMapReducePlanner.java index c184e46..705d3ce 100644 --- a/modules/hadoop/src/main/java/org/apache/ignite/hadoop/mapreduce/IgniteHadoopWeightedMapReducePlanner.java +++ b/modules/hadoop/src/main/java/org/apache/ignite/hadoop/mapreduce/IgniteHadoopWeightedMapReducePlanner.java @@ -249,9 +249,8 @@ public class IgniteHadoopWeightedMapReducePlanner extends HadoopAbstractMapReduc * @return Result. */ private UUID bestMapperNode(@Nullable Collection<UUID> affIds, HadoopMapReducePlanTopology top) { - // Priority node, may be null or empty in case if this is a Hadoop split from a data node that does - // not match any Ignite node. - final @Nullable UUID prioAffId = F.first(affIds); + // Priority node. + UUID prioAffId = F.first(affIds); // Find group with the least weight. HadoopMapReducePlanGroup resGrp = null;
