Skip to content

Commit 3cb67dc

Browse files
committed
svn merge -c 1526688 FIXES: MAPREDUCE-5513. ConcurrentModificationException in JobControl. Contributed by Robert Parker
git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/branches/branch-2@1526702 13f79535-47bb-0310-9956-ffa450edef68
1 parent 1ff2a10 commit 3cb67dc

File tree

2 files changed

+9
-5
lines changed
  • hadoop-mapreduce-project
    • hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/jobcontrol

2 files changed

+9
-5
lines changed

hadoop-mapreduce-project/CHANGES.txt

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -90,6 +90,9 @@ Release 2.1.2 - UNRELEASED
9090
MAPREDUCE-5525. Increase timeout of TestDFSIO.testAppend and
9191
TestMRJobsWithHistoryService.testJobHistoryData. (Chuan Liu via cnauroth)
9292

93+
MAPREDUCE-5513. ConcurrentModificationException in JobControl (Robert
94+
Parker via jlowe)
95+
9396
Release 2.1.1-beta - 2013-09-23
9497

9598
INCOMPATIBLE CHANGES
@@ -1284,6 +1287,9 @@ Release 0.23.10 - UNRELEASED
12841287
MAPREDUCE-5504. mapred queue -info inconsistent with types (Kousuke Saruta
12851288
via tgraves)
12861289

1290+
MAPREDUCE-5513. ConcurrentModificationException in JobControl (Robert
1291+
Parker via jlowe)
1292+
12871293
Release 0.23.9 - 2013-07-08
12881294

12891295
INCOMPATIBLE CHANGES

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

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -77,13 +77,11 @@ public JobControl(String groupName) {
7777
this.runnerState = ThreadState.READY;
7878
}
7979

80-
private static List<ControlledJob> toList(
80+
synchronized private static List<ControlledJob> toList(
8181
LinkedList<ControlledJob> jobs) {
8282
ArrayList<ControlledJob> retv = new ArrayList<ControlledJob>();
83-
synchronized (jobs) {
84-
for (ControlledJob job : jobs) {
85-
retv.add(job);
86-
}
83+
for (ControlledJob job : jobs) {
84+
retv.add(job);
8785
}
8886
return retv;
8987
}

0 commit comments

Comments
 (0)