You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by om...@apache.org on 2011/03/04 05:40:28 UTC
svn commit: r1077651 -
/hadoop/common/branches/branch-0.20-security-patches/src/contrib/gridmix/src/java/org/apache/hadoop/mapred/gridmix/Statistics.java
Author: omalley
Date: Fri Mar 4 04:40:27 2011
New Revision: 1077651
URL: http://svn.apache.org/viewvc?rev=1077651&view=rev
Log:
commit 5de997c9ce0e6f5dcdc53a6d11ca8d655eba512f
Author: Hong Tang <ht...@coatsatfind-lm.local>
Date: Thu Aug 12 02:12:51 2010 -0700
MAPREDUCE-1961. ConcurrentModificationException when shutting down Gridmix. From https://issues.apache.org/jira/secure/attachment/12450368/mr-1961-20100723.patch. (htang)
+++ b/YAHOO-CHANGES.txt
+ MAPREDUCE-1961. ConcurrentModificationException when shutting down Gridmix.
+ (htang)
+
Modified:
hadoop/common/branches/branch-0.20-security-patches/src/contrib/gridmix/src/java/org/apache/hadoop/mapred/gridmix/Statistics.java
Modified: hadoop/common/branches/branch-0.20-security-patches/src/contrib/gridmix/src/java/org/apache/hadoop/mapred/gridmix/Statistics.java
URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-0.20-security-patches/src/contrib/gridmix/src/java/org/apache/hadoop/mapred/gridmix/Statistics.java?rev=1077651&r1=1077650&r2=1077651&view=diff
==============================================================================
--- hadoop/common/branches/branch-0.20-security-patches/src/contrib/gridmix/src/java/org/apache/hadoop/mapred/gridmix/Statistics.java (original)
+++ hadoop/common/branches/branch-0.20-security-patches/src/contrib/gridmix/src/java/org/apache/hadoop/mapred/gridmix/Statistics.java Fri Mar 4 04:40:27 2011
@@ -30,11 +30,11 @@ import org.apache.hadoop.tools.rumen.Job
import java.io.IOException;
import java.security.PrivilegedExceptionAction;
-import java.util.ArrayList;
import java.util.Collection;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.CopyOnWriteArrayList;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.Condition;
@@ -56,11 +56,11 @@ public class Statistics implements Compo
//List of cluster status listeners.
private final List<StatListener<ClusterStats>> clusterStatlisteners =
- new ArrayList<StatListener<ClusterStats>>();
+ new CopyOnWriteArrayList<StatListener<ClusterStats>>();
//List of job status listeners.
private final List<StatListener<JobStats>> jobStatListeners =
- new ArrayList<StatListener<JobStats>>();
+ new CopyOnWriteArrayList<StatListener<JobStats>>();
//List of jobids and noofMaps for each job
private static final Map<Integer, JobStats> jobMaps =