azkaban-aplcache

TriggerManager needs to persist updated trigger when updating

8/10/2017 8:04:13 PM

Details

diff --git a/azkaban-common/src/main/java/azkaban/trigger/TriggerManager.java b/azkaban-common/src/main/java/azkaban/trigger/TriggerManager.java
index e554efc..5b52abe 100644
--- a/azkaban-common/src/main/java/azkaban/trigger/TriggerManager.java
+++ b/azkaban-common/src/main/java/azkaban/trigger/TriggerManager.java
@@ -137,6 +137,11 @@ public class TriggerManager extends EventHandler implements
       this.runnerThread.deleteTrigger(triggerIdMap.get(t.getTriggerId()));
       this.runnerThread.addTrigger(t);
       triggerIdMap.put(t.getTriggerId(), t);
+      try {
+        this.triggerLoader.updateTrigger(t);
+      } catch (final TriggerLoaderException e) {
+        throw new TriggerManagerException(e);
+      }
     }
   }