eagle-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From h..@apache.org
Subject eagle git commit: MINOR: change UserPrinciple into User in JHFSparkEventReader.java
Date Sat, 18 Mar 2017 16:30:25 GMT
Repository: eagle
Updated Branches:
  refs/heads/master c616c22c0 -> 4e8d8c205


MINOR: change UserPrinciple into User in JHFSparkEventReader.java

Author: Zhao, Qingwen <qingwzhao@apache.org>

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 <qingwzhao@apache.org>
Authored: Sun Mar 19 00:28:44 2017 +0800
Committer: Hao Chen <hao@apache.org>
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);
         }


Mime
View raw message