Debug output #10

tillrohrmann · Jan 17, 2015 · e701702 · e701702
1 parent 5f1b950
commit e701702
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/scheduler/Scheduler.java b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/scheduler/Scheduler.java
@@ -352,6 +352,7 @@ protected SimpleSlot getFreeSubSlotForTask(ExecutionVertex vertex,
 		// we need potentially to loop multiple times, because there may be false positives
 		// in the set-with-available-instances
 		while (true) {
+			System.out.println("Get free sub slot for " + vertex + " constraint " + constraint);
 			Pair<Instance, Locality> instanceLocalityPair = findInstance(requestedLocations);
 
 			if(instanceLocalityPair == null){