[ZEPPELIN-3529] Add uName into jobGroupId for checking user

tylerba-f · Nov 5, 2018 · b1da18c · b1da18c
1 parent d3028c2
commit b1da18c
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/spark/interpreter/src/main/java/org/apache/zeppelin/spark/Utils.java b/spark/interpreter/src/main/java/org/apache/zeppelin/spark/Utils.java
@@ -149,7 +149,11 @@ static boolean isSpark2() {
   }
 
   public static String buildJobGroupId(InterpreterContext context) {
-    return "zeppelin-" + context.getNoteId() + "-" + context.getParagraphId();
+    String uName = "anonymous";
+    if (context.getAuthenticationInfo() != null) {
+      uName = getUserName(context.getAuthenticationInfo());
+    }
+    return "zeppelin-" + uName + "-" + context.getNoteId() + "-" + context.getParagraphId();
   }
 
   public static String buildJobDesc(InterpreterContext context) {