ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From voze...@apache.org
Subject [2/4] ignite git commit: IGNITE-3414: Minors.
Date Tue, 05 Jul 2016 12:39:00 GMT
IGNITE-3414: Minors.


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/e561c9c8
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/e561c9c8
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/e561c9c8

Branch: refs/heads/ignite-3414
Commit: e561c9c8fac1b9d215ac3d8295a4062a10990b46
Parents: 3686ca5
Author: vozerov-gridgain <vozerov@gridgain.com>
Authored: Tue Jul 5 15:16:24 2016 +0300
Committer: vozerov-gridgain <vozerov@gridgain.com>
Committed: Tue Jul 5 15:16:24 2016 +0300

----------------------------------------------------------------------
 .../mapreduce/IgniteHadoopWeightedMapReducePlanner.java  | 11 ++++-------
 1 file changed, 4 insertions(+), 7 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/e561c9c8/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 907766d..eeed6e4 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
@@ -333,10 +333,9 @@ public class IgniteHadoopWeightedMapReducePlanner extends HadoopAbstractMapReduc
      * @param mappers Mappers.
      * @param reducerCnt Reducer count.
      * @return Reducers.
-     * @throws IgniteCheckedException If failed.
      */
     private Map<UUID, int[]> assignReducers(Collection<HadoopInputSplit> splits,
HadoopMapReducePlanTopology top,
-        Mappers mappers, int reducerCnt) throws IgniteCheckedException {
+        Mappers mappers, int reducerCnt) {
         Map<UUID, Integer> reducers = assignReducers0(top, splits, mappers, reducerCnt);
 
         int cnt = 0;
@@ -365,11 +364,9 @@ public class IgniteHadoopWeightedMapReducePlanner extends HadoopAbstractMapReduc
      * @param mappers Mappers.
      * @param reducerCnt Reducer count.
      * @return Reducers.
-     * @throws IgniteCheckedException If failed.
      */
     private Map<UUID, Integer> assignReducers0(HadoopMapReducePlanTopology top, Collection<HadoopInputSplit>
splits,
-        Mappers mappers, int reducerCnt)
-        throws IgniteCheckedException {
+        Mappers mappers, int reducerCnt) {
         Map<UUID, Integer> res = new HashMap<>();
 
         // Assign reducers to splits.
@@ -762,10 +759,10 @@ public class IgniteHadoopWeightedMapReducePlanner extends HadoopAbstractMapReduc
         /** Normal node. */
         NORMAL(0),
 
-        /** Affinity node. */
+        /** (likely) Affinity node. */
         HIGH(1),
 
-        /** Node with the highest priority (e.g. because it hosts more data than other nodes).
*/
+        /** (likely) Affinity node with the highest priority (e.g. because it hosts more
data than other nodes). */
         HIGHEST(2);
 
         /** Value. */


Mime
View raw message