You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@giraph.apache.org by hy...@apache.org on 2012/07/10 12:45:34 UTC
svn commit: r1359589 - in /giraph/trunk: CHANGELOG
src/main/java/org/apache/giraph/comm/NettyWorkerClient.java
Author: hyunsik
Date: Tue Jul 10 10:45:34 2012
New Revision: 1359589
URL: http://svn.apache.org/viewvc?rev=1359589&view=rev
Log:
GIRAPH-241: Small typos in var names in NettyWorkerClient.java. Contributed by Eli Reisman.
Modified:
giraph/trunk/CHANGELOG
giraph/trunk/src/main/java/org/apache/giraph/comm/NettyWorkerClient.java
Modified: giraph/trunk/CHANGELOG
URL: http://svn.apache.org/viewvc/giraph/trunk/CHANGELOG?rev=1359589&r1=1359588&r2=1359589&view=diff
==============================================================================
--- giraph/trunk/CHANGELOG (original)
+++ giraph/trunk/CHANGELOG Tue Jul 10 10:45:34 2012
@@ -2,6 +2,9 @@ Giraph Change Log
Release 0.2.0 - unreleased
+ GIRAPH-241: Small typos in var names in NettyWorkerClient.java
+ (Eli Reisman via hyunsik)
+
GIRAPH-239: IntIntNullIntVertex doesn't save halted state (apresta
via aching)
Modified: giraph/trunk/src/main/java/org/apache/giraph/comm/NettyWorkerClient.java
URL: http://svn.apache.org/viewvc/giraph/trunk/src/main/java/org/apache/giraph/comm/NettyWorkerClient.java?rev=1359589&r1=1359588&r2=1359589&view=diff
==============================================================================
--- giraph/trunk/src/main/java/org/apache/giraph/comm/NettyWorkerClient.java (original)
+++ giraph/trunk/src/main/java/org/apache/giraph/comm/NettyWorkerClient.java Tue Jul 10 10:45:34 2012
@@ -313,12 +313,12 @@ public class NettyWorkerClient<I extends
sendMessageCache.removeAllPartitionMessages();
for (Entry<Integer, Map<I, Collection<M>>> entry :
remainingMessageCache.entrySet()) {
- WritableRequest<I, V, E, M> writableReauest =
+ WritableRequest<I, V, E, M> writableRequest =
new SendPartitionMessagesRequest<I, V, E, M>(
entry.getKey(), entry.getValue());
InetSocketAddress remoteServerAddress =
getInetSocketAddress(entry.getValue().keySet().iterator().next());
- nettyClient.sendWritableRequest(remoteServerAddress, writableReauest);
+ nettyClient.sendWritableRequest(remoteServerAddress, writableRequest);
}
// Execute the remaining sends mutations (if any)
@@ -326,12 +326,12 @@ public class NettyWorkerClient<I extends
sendMutationsCache.removeAllPartitionMutations();
for (Entry<Integer, Map<I, VertexMutations<I, V, E, M>>> entry :
remainingMutationsCache.entrySet()) {
- WritableRequest<I, V, E, M> writableReauest =
+ WritableRequest<I, V, E, M> writableRequest =
new SendPartitionMutationsRequest<I, V, E, M>(
entry.getKey(), entry.getValue());
InetSocketAddress remoteServerAddress =
getInetSocketAddress(entry.getValue().keySet().iterator().next());
- nettyClient.sendWritableRequest(remoteServerAddress, writableReauest);
+ nettyClient.sendWritableRequest(remoteServerAddress, writableRequest);
}
nettyClient.waitAllRequests();