diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/AllocateResponsePBImpl.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/AllocateResponsePBImpl.java index 4643e4e..31b237c 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/AllocateResponsePBImpl.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/impl/pb/AllocateResponsePBImpl.java @@ -166,10 +166,10 @@ public synchronized void setAvailableResources(Resource limit) { public synchronized void setUpdatedNodes( final List updatedNodes) { if (updatedNodes == null) { - this.updatedNodes.clear(); return; } - this.updatedNodes = new ArrayList(updatedNodes.size()); + initLocalNewNodeReportList(); + this.updatedNodes.clear(); this.updatedNodes.addAll(updatedNodes); }