giraph-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hyun...@apache.org
Subject svn commit: r1359589 - in /giraph/trunk: CHANGELOG src/main/java/org/apache/giraph/comm/NettyWorkerClient.java
Date Tue, 10 Jul 2012 10:45:34 GMT
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();



Mime
View raw message