From b1da18c46860be453c2cde72439ecb3bb08bef0c Mon Sep 17 00:00:00 2001
From: Jaehoon Jeong <jaehoon.jeong@woowahan.com>
Date: Tue, 5 Jun 2018 21:02:16 +0900
Subject: [PATCH] [ZEPPELIN-3529] Add uName into jobGroupId for checking user

---
 .../src/main/java/org/apache/zeppelin/spark/Utils.java      | 6 +++++-
 1 file changed, 5 insertions(+), 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
index cd6c6070a71..7e7e7d1d495 100644
--- 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) {