[FLINK-19306][coordination] Add DeclarativeSlotManager

ecerulm · Oct 16, 2020 · e44c932 · e44c932
1 parent 3d7f96a
commit e44c932
Show file tree

Hide file tree

Showing 12 changed files with 1,877 additions and 6 deletions.
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java b/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
@@ -65,6 +65,7 @@
 import org.apache.flink.runtime.rpc.FencedRpcEndpoint;
 import org.apache.flink.runtime.rpc.RpcService;
 import org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils;
+import org.apache.flink.runtime.slots.ResourceRequirement;
 import org.apache.flink.runtime.taskexecutor.FileType;
 import org.apache.flink.runtime.taskexecutor.SlotReport;
 import org.apache.flink.runtime.taskexecutor.TaskExecutorGateway;
@@ -1190,6 +1191,11 @@ public void notifyAllocationFailure(JobID jobId, AllocationID allocationId, Exce
 				jobManagerRegistration.getJobManagerGateway().notifyAllocationFailure(allocationId, cause);
 			}
 		}
+
+		@Override
+		public void notifyNotEnoughResourcesAvailable(JobID jobId, Collection<ResourceRequirement> acquiredResources) {
+			validateRunsInMainThread();
+		}
 	}
 
 	private class JobLeaderIdActionsImpl implements JobLeaderIdActions {