diff --git a/server/src/com/cloud/agent/manager/AgentManagerImpl.java b/server/src/com/cloud/agent/manager/AgentManagerImpl.java
index f8724603d8f..10a9087b785 100755
--- a/server/src/com/cloud/agent/manager/AgentManagerImpl.java
+++ b/server/src/com/cloud/agent/manager/AgentManagerImpl.java
@@ -1423,11 +1423,6 @@ public class AgentManagerImpl implements AgentManager, HandlerFactory, Manager {
                 return null;
             }
 
-            if (!answer.getResult()) {
-                s_logger.warn("Unable to execute command: " + cmd.toString() + " due to " + answer.getDetails());
-                return null;
-            }
-
             if (s_logger.isDebugEnabled() && answer.getDetails() != null) {
                 s_logger.debug("Details from executing " + cmd.getClass().toString() + ": " + answer.getDetails());
             }
diff --git a/server/src/com/cloud/storage/StorageManagerImpl.java b/server/src/com/cloud/storage/StorageManagerImpl.java
index 686a4b14318..0cfff696068 100755
--- a/server/src/com/cloud/storage/StorageManagerImpl.java
+++ b/server/src/com/cloud/storage/StorageManagerImpl.java
@@ -1408,12 +1408,16 @@ public class StorageManagerImpl implements StorageManager, StorageService, Manag
         if (answer != null && answer.getResult()) {
             return true;
         } else {
+            _storagePoolDao.expunge(pool.getId());
+            String msg = "";
             if (answer != null) {
-                s_logger.warn(" can not create strorage pool through host " + hostId + " due to " + answer.getDetails());
+                msg = "Can not create strorage pool through host " + hostId + " due to " + answer.getDetails();
+                s_logger.warn(msg);
             } else {
-                s_logger.warn(" can not create strorage pool through host " + hostId + " due to CreateStoragePoolCommand returns null");
+                msg = "Can not create strorage pool through host " + hostId + " due to CreateStoragePoolCommand returns null";
+                s_logger.warn(msg);
             }
-            return false;
+            throw new CloudRuntimeException(msg);
         }
     }