You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by an...@apache.org on 2014/09/03 03:50:56 UTC
git commit: [SPARK-2981][GraphX] EdgePartition1D Int overflow
Repository: spark
Updated Branches:
refs/heads/master 7c9bbf172 -> aa7de128c
[SPARK-2981][GraphX] EdgePartition1D Int overflow
minor fix
detail is here: https://issues.apache.org/jira/browse/SPARK-2981
Author: Larry Xiao <xi...@sjtu.edu.cn>
Closes #1902 from larryxiao/2981 and squashes the following commits:
88059a2 [Larry Xiao] [SPARK-2981][GraphX] EdgePartition1D Int overflow
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/aa7de128
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/aa7de128
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/aa7de128
Branch: refs/heads/master
Commit: aa7de128c5987fd2e134736f07ae913ad1f5eb26
Parents: 7c9bbf1
Author: Larry Xiao <xi...@sjtu.edu.cn>
Authored: Tue Sep 2 18:50:52 2014 -0700
Committer: Ankur Dave <an...@gmail.com>
Committed: Tue Sep 2 18:50:52 2014 -0700
----------------------------------------------------------------------
.../src/main/scala/org/apache/spark/graphx/PartitionStrategy.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/aa7de128/graphx/src/main/scala/org/apache/spark/graphx/PartitionStrategy.scala
----------------------------------------------------------------------
diff --git a/graphx/src/main/scala/org/apache/spark/graphx/PartitionStrategy.scala b/graphx/src/main/scala/org/apache/spark/graphx/PartitionStrategy.scala
index 5e7e72a..13033fe 100644
--- a/graphx/src/main/scala/org/apache/spark/graphx/PartitionStrategy.scala
+++ b/graphx/src/main/scala/org/apache/spark/graphx/PartitionStrategy.scala
@@ -91,7 +91,7 @@ object PartitionStrategy {
case object EdgePartition1D extends PartitionStrategy {
override def getPartition(src: VertexId, dst: VertexId, numParts: PartitionID): PartitionID = {
val mixingPrime: VertexId = 1125899906842597L
- (math.abs(src) * mixingPrime).toInt % numParts
+ (math.abs(src * mixingPrime) % numParts).toInt
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org