hadoop-common-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From omal...@apache.org
Subject svn commit: r1077651 - /hadoop/common/branches/branch-0.20-security-patches/src/contrib/gridmix/src/java/org/apache/hadoop/mapred/gridmix/Statistics.java
Date Fri, 04 Mar 2011 04:40:28 GMT
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 <htang@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 =



Mime
View raw message