From 7582dedad1c73eabdc3eeece0a3a860e7bb33c1a Mon Sep 17 00:00:00 2001 From: Naganarasimha Date: Sun, 18 Jun 2017 19:53:42 +0530 Subject: [PATCH] YARN-6517. Fix warnings from Spotbugs in hadoop-yarn-common(addendum). Contributed by Weiwei Yang. --- .../yarn/logaggregation/AggregatedLogFormat.java | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/logaggregation/AggregatedLogFormat.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/logaggregation/AggregatedLogFormat.java index e5cb2553a87..d806b121e0f 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/logaggregation/AggregatedLogFormat.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/logaggregation/AggregatedLogFormat.java @@ -310,12 +310,17 @@ public String getUser() { } private Set getPendingLogFilesToUpload(File containerLogDir) { - if(containerLogDir == null || - containerLogDir.listFiles() == null) { + if(containerLogDir == null) { return new HashSet<>(0); } + + File[] filesList = containerLogDir.listFiles(); + if (filesList == null) { + return new HashSet<>(0); + } + Set candidates = - new HashSet(Arrays.asList(containerLogDir.listFiles())); + new HashSet(Arrays.asList(filesList)); for (File logFile : candidates) { this.allExistingFileMeta.add(getLogFileMetaData(logFile)); }