Index: ql/src/java/org/apache/hadoop/hive/ql/QueryPlan.java =================================================================== --- ql/src/java/org/apache/hadoop/hive/ql/QueryPlan.java (revision 1377578) +++ ql/src/java/org/apache/hadoop/hive/ql/QueryPlan.java (working copy) @@ -23,6 +23,7 @@ import java.util.ArrayList; import java.util.Calendar; import java.util.Collection; +import java.util.Collections; import java.util.GregorianCalendar; import java.util.HashMap; import java.util.HashSet; @@ -112,7 +113,7 @@ query.setQueryId(queryId); query.putToQueryAttributes("queryString", this.queryString); counters = new HashMap>(); - done = new HashSet(); + done = Collections.synchronizedSet(new HashSet()); started = new HashSet(); queryProperties = sem.getQueryProperties(); queryStartTime = startTime;