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 <[email protected]> Authored: Mon Feb 3 09:30:17 2014 -0800 Committer: Maja Kabiljo <[email protected]> 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();
