[3/8] storm git commit: Catching and ignoring the exception during prepare as well.

[pa...@apache.org]

Catching and ignoring the exception during prepare as well.


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/405b8534
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/405b8534
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/405b8534

Branch: refs/heads/master
Commit: 405b853450b339057e83c38094bedb2c30df8a60
Parents: ea2c2d2
Author: Parth Brahmbhatt <br...@gmail.com>
Authored: Fri Nov 6 13:29:53 2015 -0800
Committer: Parth Brahmbhatt <br...@gmail.com>
Committed: Fri Nov 6 13:29:53 2015 -0800

----------------------------------------------------------------------
 storm-core/src/clj/backtype/storm/daemon/nimbus.clj | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/405b8534/storm-core/src/clj/backtype/storm/daemon/nimbus.clj
----------------------------------------------------------------------
diff --git a/storm-core/src/clj/backtype/storm/daemon/nimbus.clj b/storm-core/src/clj/backtype/storm/daemon/nimbus.clj
index 57f6c75..d570a76 100644
--- a/storm-core/src/clj/backtype/storm/daemon/nimbus.clj
+++ b/storm-core/src/clj/backtype/storm/daemon/nimbus.clj
@@ -97,9 +97,11 @@
 (defn create-tology-action-notifier [conf]
   (when-not (clojure.string/blank? (conf NIMBUS-TOPOLOGY-ACTION-NOTIFIER-PLUGIN))
     (let [instance (new-instance (conf NIMBUS-TOPOLOGY-ACTION-NOTIFIER-PLUGIN))]
-      (.prepare instance conf)
-      instance
-      )))
+      (try
+        (.prepare instance conf)
+        instance
+        (catch Exception e
+          (log-warn-error e "Ingoring exception, Could not initialize " (conf NIMBUS-TOPOLOGY-ACTION-NOTIFIER-PLUGIN)))))))
 
 (defn nimbus-data [conf inimbus]
   (let [forced-scheduler (.getForcedScheduler inimbus)]