azkaban-aplcache

fix submitted user name for trigger when deserializing from

6/23/2017 3:13:24 PM

Details

diff --git a/azkaban-common/src/main/java/azkaban/trigger/Trigger.java b/azkaban-common/src/main/java/azkaban/trigger/Trigger.java
index 8b4014f..b783628 100644
--- a/azkaban-common/src/main/java/azkaban/trigger/Trigger.java
+++ b/azkaban-common/src/main/java/azkaban/trigger/Trigger.java
@@ -150,7 +150,7 @@ public class Trigger {
         action.setContext(context);
       }
 
-      trigger = new Trigger.TriggerBuilder("azkaban",
+      trigger = new Trigger.TriggerBuilder(submitUser,
           source,
           triggerCond,
           expireCond,