big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

MAPREDUCE-5513. ConcurrentModificationException in JobControl. Contributed by Robert Parker

Browse Source 
git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/trunk@1526688 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Jason Darrell Lowe 2013-09-26 21:10:05 +00:00
parent 4402e2fcef
commit cf3d8b2286
2 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
hadoop-mapreduce-project/CHANGES.txt
View File

@ -227,6 +227,9 @@ Release 2.1.2 - UNRELEASED
MAPREDUCE-5525. Increase timeout of TestDFSIO.testAppend and MAPREDUCE-5525. Increase timeout of TestDFSIO.testAppend and
TestMRJobsWithHistoryService.testJobHistoryData. (Chuan Liu via cnauroth) TestMRJobsWithHistoryService.testJobHistoryData. (Chuan Liu via cnauroth)
MAPREDUCE-5513. ConcurrentModificationException in JobControl (Robert
Parker via jlowe)
Release 2.1.1-beta - 2013-09-23 Release 2.1.1-beta - 2013-09-23
INCOMPATIBLE CHANGES INCOMPATIBLE CHANGES
@ -1409,6 +1412,9 @@ Release 0.23.10 - UNRELEASED
MAPREDUCE-5504. mapred queue -info inconsistent with types (Kousuke Saruta MAPREDUCE-5504. mapred queue -info inconsistent with types (Kousuke Saruta
via tgraves) via tgraves)
MAPREDUCE-5513. ConcurrentModificationException in JobControl (Robert
Parker via jlowe)
Release 0.23.9 - 2013-07-08 Release 0.23.9 - 2013-07-08
INCOMPATIBLE CHANGES INCOMPATIBLE CHANGES

8
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/jobcontrol/JobControl.java
View File

@ -79,13 +79,11 @@ public JobControl(String groupName) {
this.runnerState = ThreadState.READY; this.runnerState = ThreadState.READY;
} }
private static List<ControlledJob> toList( synchronized private static List<ControlledJob> toList(
LinkedList<ControlledJob> jobs) { LinkedList<ControlledJob> jobs) {
ArrayList<ControlledJob> retv = new ArrayList<ControlledJob>(); ArrayList<ControlledJob> retv = new ArrayList<ControlledJob>();
synchronized (jobs) { for (ControlledJob job : jobs) {
for (ControlledJob job : jobs) { retv.add(job);
retv.add(job);
}
} }
return retv; return retv;
} }