TEIID-5132 adding synchronization

teiid · Jan 3, 2018 · e1db5d2 · e1db5d2
1 parent 2ac1099
commit e1db5d2
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/engine/src/main/java/org/teiid/dqp/internal/process/DQPCore.java b/engine/src/main/java/org/teiid/dqp/internal/process/DQPCore.java
@@ -412,7 +412,9 @@ public int getWaitingPlanCount() {
     }
 
     public int getMaxWaitingPlanWatermark() {
-    	return this.maxWaitingPlans;
+        synchronized (waitingPlans) {
+            return this.maxWaitingPlans;
+        }
     }
 
     void removeRequest(final RequestWorkItem workItem) {