Repository: eagle Updated Branches: refs/heads/master c616c22c0 -> 4e8d8c205
MINOR: change UserPrinciple into User in JHFSparkEventReader.java Author: Zhao, Qingwen <[email protected]> Closes #887 from qingwen220/minor. Project: http://git-wip-us.apache.org/repos/asf/eagle/repo Commit: http://git-wip-us.apache.org/repos/asf/eagle/commit/4e8d8c20 Tree: http://git-wip-us.apache.org/repos/asf/eagle/tree/4e8d8c20 Diff: http://git-wip-us.apache.org/repos/asf/eagle/diff/4e8d8c20 Branch: refs/heads/master Commit: 4e8d8c2053749193e88b49e82a07dfb2bb2edd6e Parents: c616c22 Author: Zhao, Qingwen <[email protected]> Authored: Sun Mar 19 00:28:44 2017 +0800 Committer: Hao Chen <[email protected]> Committed: Sun Mar 19 00:28:44 2017 +0800 ---------------------------------------------------------------------- .../apache/eagle/jpm/spark/history/crawl/JHFSparkEventReader.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/eagle/blob/4e8d8c20/eagle-jpm/eagle-jpm-spark-history/src/main/java/org/apache/eagle/jpm/spark/history/crawl/JHFSparkEventReader.java ---------------------------------------------------------------------- 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 d245f49..2ef1bd9 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 @@ -169,7 +169,7 @@ public class JHFSparkEventReader { // the second argument of getNormalizeName() is changed to null because the original code contains sensitive text // original second argument looks like: this.app.getConfig().getConfig().get("xxx"), "xxx" is the sensitive text entity.getTags().put(SparkJobTagName.SPARK_APP_NORM_NAME.toString(), this.getNormalizedName(JSONUtils.getString(event, "App Name"), null)); - entity.getTags().put(SparkJobTagName.SPARK_USER.toString(), JSONUtils.getString(event, "UserPrincipal")); + entity.getTags().put(SparkJobTagName.SPARK_USER.toString(), JSONUtils.getString(event, "User")); entity.setTimestamp(appStartTime); }
