[FLINK-18067][yarn] Change default value of yarnMinAllocationMB from …

…zero to DEFAULT_RM_SCHEDULER_MINIMUM_ALLOCATION_MB This closes apache#12444.
is · Jun 7, 2020 · 674817c · 674817c
1 parent d25609d
commit 674817c
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java b/flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java
@@ -504,7 +504,14 @@ private ClusterClientProvider<ApplicationId> deployInternal(
  throw new YarnDeploymentException("Could not retrieve information about free cluster resources.", e);
  }
 
- final int yarnMinAllocationMB = yarnConfiguration.getInt(YarnConfiguration.RM_SCHEDULER_MINIMUM_ALLOCATION_MB, 0);
+ final int yarnMinAllocationMB = yarnConfiguration.getInt(
+ YarnConfiguration.RM_SCHEDULER_MINIMUM_ALLOCATION_MB,
+ YarnConfiguration.DEFAULT_RM_SCHEDULER_MINIMUM_ALLOCATION_MB);
+ if (yarnMinAllocationMB <= 0) {
+ throw new YarnDeploymentException("The minimum allocation memory "
+ + "(" + yarnMinAllocationMB + " MB) configured via '" + YarnConfiguration.RM_SCHEDULER_MINIMUM_ALLOCATION_MB
+ + "' should be greater than 0.");
+ }
 
  final ClusterSpecification validClusterSpecification;
  try {