You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hama.apache.org by tj...@apache.org on 2011/12/07 11:27:15 UTC
svn commit: r1211378 -
/incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/LocalBSPRunner.java
Author: tjungblut
Date: Wed Dec 7 10:27:15 2011
New Revision: 1211378
URL: http://svn.apache.org/viewvc?rev=1211378&view=rev
Log:
Revert changes of a shared counter
Modified:
incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/LocalBSPRunner.java
Modified: incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/LocalBSPRunner.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/LocalBSPRunner.java?rev=1211378&r1=1211377&r2=1211378&view=diff
==============================================================================
--- incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/LocalBSPRunner.java (original)
+++ incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/LocalBSPRunner.java Wed Dec 7 10:27:15 2011
@@ -213,7 +213,6 @@ public class LocalBSPRunner implements J
private int id;
private BSP bsp;
private RawSplit[] splits;
- private static final Counters counters = new Counters();
public BSPRunner(Configuration conf, BSPJob job, int id, RawSplit[] splits) {
super();
@@ -244,7 +243,7 @@ public class LocalBSPRunner implements J
BSPPeerImpl peer = new BSPPeerImpl(job, conf, new TaskAttemptID(
new TaskID(job.getJobID(), id), id), new LocalUmbilical(), id,
- splitname, realBytes, counters);
+ splitname, realBytes, new Counters());
bsp.setConf(conf);
try {