[hotfix] Remove unnecessary int cast.

tongcheng-elong · Apr 30, 2018 · 290b11b · 290b11b
1 parent b209e6e
commit 290b11b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java b/flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java
@@ -286,7 +286,7 @@ public void startNewWorker(ResourceProfile resourceProfile) {
  // Priority for worker containers - priorities are intra-application
  //TODO: set priority according to the resource allocated
  Priority priority = Priority.newInstance(generatePriority(resourceProfile));
- int mem = resourceProfile.getMemoryInMB() < 0 ? defaultTaskManagerMemoryMB : (int) resourceProfile.getMemoryInMB();
+ int mem = resourceProfile.getMemoryInMB() < 0 ? defaultTaskManagerMemoryMB : resourceProfile.getMemoryInMB();
  int vcore = resourceProfile.getCpuCores() < 1 ? defaultCpus : (int) resourceProfile.getCpuCores();
  Resource capability = Resource.newInstance(mem, vcore);
  requestYarnContainer(capability, priority);