commit f529fc7d3b0156b94a13ef4a6c84fb10028b977c
author vinayakb <vinayakb@123451ca-8445-de46-9d55-352943316053> Sat Dec 17 17:03:58 2011 +0000
committer vinayakb <vinayakb@123451ca-8445-de46-9d55-352943316053> Sat Dec 17 17:03:58 2011 +0000
tree ac8432e7dbadde66bf612f1a36bcf839f52b2c70
parent eeb687966db825b8ea8e5cede32d2b4b5a15d87c

Fixed CME on HashSet

git-svn-id: https://hyracks.googlecode.com/svn/branches/hyracks_dev_next@909 123451ca-8445-de46-9d55-352943316053

hyracks-control-cc/src/main/java/edu/uci/ics/hyracks/control/cc/scheduler/JobScheduler.java

diff --git a/hyracks-control-cc/src/main/java/edu/uci/ics/hyracks/control/cc/scheduler/JobScheduler.java b/hyracks-control-cc/src/main/java/edu/uci/ics/hyracks/control/cc/scheduler/JobScheduler.java
index 6933bf0..24bee8c 100644
--- a/hyracks-control-cc/src/main/java/edu/uci/ics/hyracks/control/cc/scheduler/JobScheduler.java
+++ b/hyracks-control-cc/src/main/java/edu/uci/ics/hyracks/control/cc/scheduler/JobScheduler.java
@@ -461,10 +461,11 @@
     }
 
     private void abortJob(Exception exception) {
-        for (TaskCluster tc : inProgressTaskClusters) {
+        Set<TaskCluster> inProgressTaskClustersCopy = new HashSet<TaskCluster>(inProgressTaskClusters);
+        for (TaskCluster tc : inProgressTaskClustersCopy) {
             abortTaskCluster(findLastTaskClusterAttempt(tc));
         }
-        inProgressTaskClusters.clear();
+        assert inProgressTaskClusters.isEmpty();
         ccs.getWorkQueue().schedule(new JobCleanupWork(ccs, jobRun.getJobId(), JobStatus.FAILURE, exception));
     }