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 {