| commit | 7d39863f48916116e99cdff98527e60f9379a475 | [log] [tgz] |
|---|---|---|
| author | Zhao, Qingwen <qingwzhao@apache.org> | Fri May 19 13:49:37 2017 +0800 |
| committer | Zhao, Qingwen <qingwzhao@apache.org> | Fri May 19 13:49:37 2017 +0800 |
| tree | a328bc8dc0b2d6d426aff5d48bc7ca94fdaa17a5 | |
| parent | 342df9974c91f845608c9ff3c65b8c1818d56884 [diff] |
[EAGLE-1022] Fix runtime exception when parsing spark.yarn.executor.memoryOverhead https://issues.apache.org/jira/browse/EAGLE-1022 Author: Zhao, Qingwen <qingwzhao@apache.org> Closes #934 from qingwen220/EAGLE-1022.
diff --git a/eagle-jpm/eagle-jpm-spark-history/src/main/java/org/apache/eagle/jpm/spark/history/crawl/JHFSparkEventReader.java b/eagle-jpm/eagle-jpm-spark-history/src/main/java/org/apache/eagle/jpm/spark/history/crawl/JHFSparkEventReader.java index 2ef1bd9..45cb730 100644 --- a/eagle-jpm/eagle-jpm-spark-history/src/main/java/org/apache/eagle/jpm/spark/history/crawl/JHFSparkEventReader.java +++ b/eagle-jpm/eagle-jpm-spark-history/src/main/java/org/apache/eagle/jpm/spark/history/crawl/JHFSparkEventReader.java
@@ -487,8 +487,9 @@ long result = 0L; String fieldValue = config.getConfig().get(fieldName); if (fieldValue != null) { - result = Utils.parseMemory(fieldValue + "m"); - if (result == 0L) { + try { + result = Utils.parseMemory(fieldValue + "m"); + } catch (Exception e) { result = Utils.parseMemory(fieldValue); } }