You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vo...@apache.org on 2016/07/05 12:39:00 UTC
[2/4] ignite git commit: IGNITE-3414: Minors.
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 <vo...@gridgain.com>
Authored: Tue Jul 5 15:16:24 2016 +0300
Committer: vozerov-gridgain <vo...@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. */