Skip to content
Browse files

Do not halt the process (from within the task) when it fails in local…

…-mode
  • Loading branch information...
1 parent 0d36249 commit 729e07517ec5f8aaa479083debcc0fbe28832da9 @fbrubacher committed with Adriana Laitano Oct 16, 2011
Showing with 3 additions and 2 deletions.
  1. +3 −2 src/clj/backtype/storm/daemon/task.clj
View
5 src/clj/backtype/storm/daemon/task.clj
@@ -185,8 +185,9 @@
(.report-task-error storm-cluster-state storm-id task-id error))
report-error-and-die (fn [error]
- (report-error error)
- (halt-process! 1 "Task died"))
+ (report-error error)
+ (when (not= "local" (storm-conf STORM-CLUSTER-MODE))
+ (halt-process! 1 "Task died")))
;; heartbeat ASAP so nimbus doesn't reassign
heartbeat-thread (async-loop

0 comments on commit 729e075

Please sign in to comment.
Something went wrong with that request. Please try again.