giraph-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From m...@apache.org
Subject git commit: updated refs/heads/trunk to 9325fa9
Date Mon, 03 Feb 2014 17:30:53 GMT
Updated Branches:
  refs/heads/trunk 763621a45 -> 9325fa986


GIRAPH-839: NettyWorkerAggregatorRequestProcessor tries to reuse request objects (pavanka
via majakabiljo)


Project: http://git-wip-us.apache.org/repos/asf/giraph/repo
Commit: http://git-wip-us.apache.org/repos/asf/giraph/commit/9325fa98
Tree: http://git-wip-us.apache.org/repos/asf/giraph/tree/9325fa98
Diff: http://git-wip-us.apache.org/repos/asf/giraph/diff/9325fa98

Branch: refs/heads/trunk
Commit: 9325fa9869c2604172576f89311308915ebb416d
Parents: 763621a
Author: Maja Kabiljo <majakabiljo@fb.com>
Authored: Mon Feb 3 09:30:17 2014 -0800
Committer: Maja Kabiljo <majakabiljo@fb.com>
Committed: Mon Feb 3 09:30:17 2014 -0800

----------------------------------------------------------------------
 CHANGELOG                                                      | 3 +++
 .../comm/netty/NettyWorkerAggregatorRequestProcessor.java      | 6 +++---
 2 files changed, 6 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/giraph/blob/9325fa98/CHANGELOG
----------------------------------------------------------------------
diff --git a/CHANGELOG b/CHANGELOG
index e21a291..cef754e 100644
--- a/CHANGELOG
+++ b/CHANGELOG
@@ -1,6 +1,9 @@
 Giraph Change Log
 
 Release 1.1.0 - unreleased
+  GIRAPH-839: NettyWorkerAggregatorRequestProcessor tries to reuse request objects 
+  (pavanka via majakabiljo)
+
   GIRAPH-835: org.apache.giraph.hive.input.CheckInputTest Fails because JobProgressTracker
   doesn't check null (akila via majakabiljo)
 

http://git-wip-us.apache.org/repos/asf/giraph/blob/9325fa98/giraph-core/src/main/java/org/apache/giraph/comm/netty/NettyWorkerAggregatorRequestProcessor.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/comm/netty/NettyWorkerAggregatorRequestProcessor.java
b/giraph-core/src/main/java/org/apache/giraph/comm/netty/NettyWorkerAggregatorRequestProcessor.java
index 798e09c..8b5f293 100644
--- a/giraph-core/src/main/java/org/apache/giraph/comm/netty/NettyWorkerAggregatorRequestProcessor.java
+++ b/giraph-core/src/main/java/org/apache/giraph/comm/netty/NettyWorkerAggregatorRequestProcessor.java
@@ -124,11 +124,11 @@ public class NettyWorkerAggregatorRequestProcessor
   public void distributeAggregators(
       Iterable<byte[]> aggregatorDataList) throws IOException {
     for (byte[] aggregatorData : aggregatorDataList) {
-      SendAggregatorsToWorkerRequest request =
-          new SendAggregatorsToWorkerRequest(aggregatorData,
-              serviceWorker.getWorkerInfo().getTaskId());
       for (WorkerInfo worker : serviceWorker.getWorkerInfoList()) {
         if (!isThisWorker(worker)) {
+          SendAggregatorsToWorkerRequest request =
+              new SendAggregatorsToWorkerRequest(aggregatorData,
+                  serviceWorker.getWorkerInfo().getTaskId());
           workerClient.sendWritableRequest(worker.getTaskId(), request);
         }
         progressable.progress();


Mime
View raw message