From f8e5e621d84e8f266facec23b514f187348ec877 Mon Sep 17 00:00:00 2001 From: Cosmin Lehene Date: Wed, 26 Jun 2013 17:03:40 +0300 Subject: [PATCH] Runtime ClassCastException while attempting to log problems with file deletion while cleaning inbox. --- storm-core/src/clj/backtype/storm/daemon/nimbus.clj | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/storm-core/src/clj/backtype/storm/daemon/nimbus.clj b/storm-core/src/clj/backtype/storm/daemon/nimbus.clj index e58aeedd0a..e27e0af018 100644 --- a/storm-core/src/clj/backtype/storm/daemon/nimbus.clj +++ b/storm-core/src/clj/backtype/storm/daemon/nimbus.clj @@ -829,8 +829,7 @@ (doseq [f files] (if (.delete f) (log-message "Cleaning inbox ... deleted: " (.getName f)) - ;; This should never happen - (log-error "Cleaning inbox ... error deleting: " (.getName f)) + (throw (RuntimeException. (str "Failed clean inbox. Failed to delete " (.getName f) ". Check file permissions."))) )))) (defn cleanup-corrupt-topologies! [nimbus]