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);
   }


Reply via email to