Kaynağa Gözat

MAPREDUCE-7191. JobHistoryServer should log exception when loading/parsing history file failed. Contributed by Jiandan Yang.

(cherry picked from commit f0605146b34ddbd19fc9e52d4761f9a347d5173e)
Weiwei Yang 6 yıl önce
ebeveyn
işleme
301ffee1bc

+ 9 - 6
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-hs/src/main/java/org/apache/hadoop/mapreduce/v2/hs/CompletedJob.java

@@ -380,17 +380,20 @@ public class CompletedJob implements org.apache.hadoop.mapreduce.v2.app.job.Job
         parser = createJobHistoryParser(historyFileAbsolute);
         this.jobInfo = parser.parse();
       } catch (IOException e) {
-        throw new YarnRuntimeException("Could not load history file "
-            + historyFileAbsolute, e);
+        String errorMsg = "Could not load history file " + historyFileAbsolute;
+        LOG.warn(errorMsg, e);
+        throw new YarnRuntimeException(errorMsg, e);
       }
       IOException parseException = parser.getParseException(); 
       if (parseException != null) {
-        throw new YarnRuntimeException(
-            "Could not parse history file " + historyFileAbsolute, 
-            parseException);
+        String errorMsg = "Could not parse history file " + historyFileAbsolute;
+        LOG.warn(errorMsg, parseException);
+        throw new YarnRuntimeException(errorMsg, parseException);
       }
     } else {
-      throw new IOException("History file not found");
+      String errorMsg = "History file not found";
+      LOG.warn(errorMsg);
+      throw new IOException(errorMsg);
     }
     if (loadTasks) {
       loadAllTasks();