Author: aching
Date: Fri Sep 7 21:35:59 2012
New Revision: 1382184
URL: http://svn.apache.org/viewvc?rev=1382184&view=rev
Log:
GIRAPH-321: Divide by 0 exception. (ereisman via aching)
Modified:
giraph/trunk/CHANGELOG
giraph/trunk/src/main/java/org/apache/giraph/graph/LocalityInfoSorter.java
Modified: giraph/trunk/CHANGELOG
URL:
http://svn.apache.org/viewvc/giraph/trunk/CHANGELOG?rev=1382184&r1=1382183&r2=1382184&view=diff
==============================================================================
--- giraph/trunk/CHANGELOG (original)
+++ giraph/trunk/CHANGELOG Fri Sep 7 21:35:59 2012
@@ -1,6 +1,9 @@
Giraph Change Log
Release 0.2.0 - unreleased
+
+ GIRAPH-321: Divide by 0 exception. (ereisman via aching)
+
GIRAPH-316: Add test-patch.sh for precommit test using Jenkins.
(hyunsik via ereisman)
Modified:
giraph/trunk/src/main/java/org/apache/giraph/graph/LocalityInfoSorter.java
URL:
http://svn.apache.org/viewvc/giraph/trunk/src/main/java/org/apache/giraph/graph/LocalityInfoSorter.java?rev=1382184&r1=1382183&r2=1382184&view=diff
==============================================================================
--- giraph/trunk/src/main/java/org/apache/giraph/graph/LocalityInfoSorter.java
(original)
+++ giraph/trunk/src/main/java/org/apache/giraph/graph/LocalityInfoSorter.java
Fri Sep 7 21:35:59 2012
@@ -104,8 +104,10 @@ public class LocalityInfoSorter implemen
// determine the hash-based offset for this worker to iterate from
// and place the local blocks into the list at that index, if any
final int temp = hostName.hashCode() + (19 * port);
- baseOffset =
- Math.abs(temp == Integer.MIN_VALUE ? 0 : temp) % pathList.size();
+ if (pathList.size() != 0) {
+ baseOffset =
+ Math.abs(temp == Integer.MIN_VALUE ? 0 : temp) % pathList.size();
+ }
// re-insert local paths at "adjusted index zero" for caller to iterate on
pathList.addAll(baseOffset, sortedList);
}