From 72d90e750bd1b812f64c37432715fec4af88a7e0 Mon Sep 17 00:00:00 2001 From: Daniel Templeton Date: Mon, 16 Oct 2017 11:43:54 -0700 Subject: [PATCH] YARN-7270 addendum: Reapplied changes after YARN-3926 backports --- .../java/org/apache/hadoop/yarn/api/records/Resource.java | 4 ++-- .../hadoop/yarn/api/records/impl/LightWeightResource.java | 4 ++-- .../hadoop/yarn/api/records/impl/pb/ResourcePBImpl.java | 2 +- 3 files changed, 5 insertions(+), 5 deletions(-) diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/records/Resource.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/records/Resource.java index 37b50f28ba7..be0ab58be83 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/records/Resource.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/records/Resource.java @@ -285,7 +285,7 @@ public void setResourceInformation(String resource, return; } if (resource.equals(ResourceInformation.VCORES_URI)) { - this.setVirtualCores((int) resourceInformation.getValue()); + this.setVirtualCores(castToIntSafely(resourceInformation.getValue())); return; } ResourceInformation storedResourceInfo = getResourceInformation(resource); @@ -331,7 +331,7 @@ public void setResourceValue(String resource, long value) return; } if (resource.equals(ResourceInformation.VCORES_URI)) { - this.setVirtualCores((int)value); + this.setVirtualCores(castToIntSafely(value)); return; } diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/records/impl/LightWeightResource.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/records/impl/LightWeightResource.java index b80e13388cf..a64d242a4ab 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/records/impl/LightWeightResource.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/records/impl/LightWeightResource.java @@ -92,7 +92,7 @@ private static ResourceInformation newDefaultInformation(String name, @Override @SuppressWarnings("deprecation") public int getMemory() { - return (int) memoryResInfo.getValue(); + return castToIntSafely(memoryResInfo.getValue()); } @Override @@ -113,7 +113,7 @@ public void setMemorySize(long memory) { @Override public int getVirtualCores() { - return (int) vcoresResInfo.getValue(); + return castToIntSafely(vcoresResInfo.getValue()); } @Override diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/records/impl/pb/ResourcePBImpl.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/records/impl/pb/ResourcePBImpl.java index 06c30ffb708..4ae64c2582a 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/records/impl/pb/ResourcePBImpl.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/api/records/impl/pb/ResourcePBImpl.java @@ -117,7 +117,7 @@ public void setMemorySize(long memory) { @Override public int getVirtualCores() { // vcores should always be present - return (int) resources[VCORES_INDEX].getValue(); + return castToIntSafely(resources[VCORES_INDEX].getValue()); } @Override