Author: aching
Date: Wed Jan 18 23:04:46 2012
New Revision: 1233107
URL: http://svn.apache.org/viewvc?rev=1233107&view=rev
Log:
GIRAPH-125: Bug in LongDoubleFloatDoubleVertex.sendMsgToAllEdges().
(humming80 via aching)
Modified:
incubator/giraph/trunk/CHANGELOG
incubator/giraph/trunk/src/main/java/org/apache/giraph/graph/LongDoubleFloatDoubleVertex.java
Modified: incubator/giraph/trunk/CHANGELOG
URL:
http://svn.apache.org/viewvc/incubator/giraph/trunk/CHANGELOG?rev=1233107&r1=1233106&r2=1233107&view=diff
==============================================================================
--- incubator/giraph/trunk/CHANGELOG (original)
+++ incubator/giraph/trunk/CHANGELOG Wed Jan 18 23:04:46 2012
@@ -1,10 +1,13 @@
Giraph Change Log
Release 0.1.0 - unreleased
+
+ GIRAPH-125: Bug in LongDoubleFloatDoubleVertex.sendMsgToAllEdges().
+ (humming80 via aching)
- GIRAPH-122. Roll version back to 0.1. (jghoman)
+ GIRAPH-122: Roll version back to 0.1. (jghoman)
- GIRAPH-118: Clarify messages behavior in BasicVertex (claudio)
+ GIRAPH-118: Clarify messages behavior in BasicVertex. (claudio)
GIRAPH-119: VertexCombiner should work on Iterable<M> instead of
List<M>. (claudio)
Modified:
incubator/giraph/trunk/src/main/java/org/apache/giraph/graph/LongDoubleFloatDoubleVertex.java
URL:
http://svn.apache.org/viewvc/incubator/giraph/trunk/src/main/java/org/apache/giraph/graph/LongDoubleFloatDoubleVertex.java?rev=1233107&r1=1233106&r2=1233107&view=diff
==============================================================================
---
incubator/giraph/trunk/src/main/java/org/apache/giraph/graph/LongDoubleFloatDoubleVertex.java
(original)
+++
incubator/giraph/trunk/src/main/java/org/apache/giraph/graph/LongDoubleFloatDoubleVertex.java
Wed Jan 18 23:04:46 2012
@@ -134,14 +134,12 @@ public abstract class LongDoubleFloatDou
throw new IllegalArgumentException(
"sendMsgToAllEdges: Cannot send null message to all edges");
}
- final LongWritable destVertex = new LongWritable();
final MutableVertex<LongWritable, DoubleWritable, FloatWritable,
DoubleWritable> vertex = this;
verticesWithEdgeValues.forEachKey(new LongProcedure() {
@Override
public boolean apply(long destVertexId) {
- destVertex.set(destVertexId);
- vertex.sendMsg(destVertex, msg);
+ vertex.sendMsg(new LongWritable(destVertexId), msg);
return true;
}
});