Github user HeartSaVioR commented on the pull request: https://github.com/apache/storm/pull/280#issuecomment-57930437 @ChitturiPadma I've just test killing topology using Storm 0.9.2. There're some warning but supervisor seems to not killed. It seems to have an issue you mentioned (about file deletion) but workers completely killed. I can re-submit topology and it's running fine. ``` 2014-10-05 17:48:50 b.s.d.supervisor [INFO] Shutting down 95111631-8f7f-46ed-a93a-8db1d01ae4e0:154eaf07-90ed-4f84-ad84-3b3b4eb51444 2014-10-05 17:48:53 b.s.d.supervisor [INFO] Shutting down and clearing state for id 154eaf07-90ed-4f84-ad84-3b3b4eb51444. Current supervisor time: 1412498932. State: :disallowed, Heartbeat: #backtype.storm.daemon.common.WorkerHeartbeat{:time-secs 1412498932, :storm-id "production-topology-1-1412498729", :executors #{[2 2] [5 5] [8 8] [11 11] [14 14] [17 17] [20 20] [23 23] [26 26] [-1 -1]}, :port 6701} 2014-10-05 17:48:53 b.s.d.supervisor [INFO] Shutting down 95111631-8f7f-46ed-a93a-8db1d01ae4e0:154eaf07-90ed-4f84-ad84-3b3b4eb51444 2014-10-05 17:48:59 b.s.d.supervisor [INFO] Shut down 95111631-8f7f-46ed-a93a-8db1d01ae4e0:154eaf07-90ed-4f84-ad84-3b3b4eb51444 2014-10-05 17:48:59 b.s.d.supervisor [INFO] Shutting down 95111631-8f7f-46ed-a93a-8db1d01ae4e0:816a0fd6-7cdf-4312-a5ac-758f7f55ce46 2014-10-05 17:48:59 b.s.util [INFO] Error when trying to kill 4408. Process is probably already dead. 2014-10-05 17:49:03 b.s.util [INFO] Error when trying to kill 4420. Process is probably already dead. 2014-10-05 17:49:03 b.s.d.supervisor [INFO] Shut down 95111631-8f7f-46ed-a93a-8db1d01ae4e0:154eaf07-90ed-4f84-ad84-3b3b4eb51444 2014-10-05 17:49:03 b.s.d.supervisor [INFO] Shutting down and clearing state for id 816a0fd6-7cdf-4312-a5ac-758f7f55ce46. Current supervisor time: 1412498932. State: :disallowed, Heartbeat: #backtype.storm.daemon.common.WorkerHeartbeat{:time-secs 1412498932, :storm-id "production-topology-1-1412498729", :executors #{[3 3] [6 6] [9 9] [12 12] [15 15] [18 18] [21 21] [24 24] [27 27] [-1 -1]}, :port 6702} 2014-10-05 17:49:03 b.s.d.supervisor [INFO] Shutting down 95111631-8f7f-46ed-a93a-8db1d01ae4e0:816a0fd6-7cdf-4312-a5ac-758f7f55ce46 2014-10-05 17:49:04 b.s.d.supervisor [WARN] Failed to cleanup worker 816a0fd6-7cdf-4312-a5ac-758f7f55ce46. Will retry later #<RuntimeException java.lang.RuntimeException: Failed to delete storm-local\workers\816a0fd6-7cdf-4312-a5ac-758f7f55ce46> 2014-10-05 17:49:04 b.s.d.supervisor [INFO] Shut down 95111631-8f7f-46ed-a93a-8db1d01ae4e0:816a0fd6-7cdf-4312-a5ac-758f7f55ce46 2014-10-05 17:49:04 b.s.d.supervisor [INFO] Shutting down and clearing state for id c26b2e31-d006-4d4d-9e56-45ca9391018d. Current supervisor time: 1412498932. State: :disallowed, Heartbeat: #backtype.storm.daemon.common.WorkerHeartbeat{:time-secs 1412498932, :storm-id "production-topology-1-1412498729", :executors #{[4 4] [7 7] [10 10] [13 13] [16 16] [19 19] [22 22] [25 25] [28 28] [-1 -1] [1 1]}, :port 6700} 2014-10-05 17:49:04 b.s.d.supervisor [INFO] Shutting down 95111631-8f7f-46ed-a93a-8db1d01ae4e0:c26b2e31-d006-4d4d-9e56-45ca9391018d 2014-10-05 17:49:04 b.s.d.supervisor [WARN] Failed to cleanup worker 816a0fd6-7cdf-4312-a5ac-758f7f55ce46. Will retry later #<RuntimeException java.lang.RuntimeException: Failed to delete storm-local\workers\816a0fd6-7cdf-4312-a5ac-758f7f55ce46> 2014-10-05 17:49:04 b.s.d.supervisor [INFO] Shut down 95111631-8f7f-46ed-a93a-8db1d01ae4e0:816a0fd6-7cdf-4312-a5ac-758f7f55ce46 2014-10-05 17:49:04 b.s.d.supervisor [INFO] Shutting down 95111631-8f7f-46ed-a93a-8db1d01ae4e0:c26b2e31-d006-4d4d-9e56-45ca9391018d 2014-10-05 17:49:04 b.s.util [INFO] Error when trying to kill 1536. Process is probably already dead. 2014-10-05 17:49:06 b.s.util [INFO] Error when trying to kill 3408. Process is probably already dead. 2014-10-05 17:49:06 b.s.util [INFO] Error when trying to kill 3464. Process is probably already dead. 2014-10-05 17:49:06 b.s.d.supervisor [WARN] Failed to cleanup worker c26b2e31-d006-4d4d-9e56-45ca9391018d. Will retry later #<RuntimeException java.lang.RuntimeException: Failed to delete storm-local\workers\c26b2e31-d006-4d4d-9e56-45ca9391018d> 2014-10-05 17:49:06 b.s.d.supervisor [INFO] Shut down 95111631-8f7f-46ed-a93a-8db1d01ae4e0:c26b2e31-d006-4d4d-9e56-45ca9391018d 2014-10-05 17:49:06 b.s.d.supervisor [WARN] Failed to cleanup worker c26b2e31-d006-4d4d-9e56-45ca9391018d. Will retry later #<RuntimeException java.lang.RuntimeException: Failed to delete storm-local\workers\c26b2e31-d006-4d4d-9e56-45ca9391018d> 2014-10-05 17:49:06 b.s.d.supervisor [INFO] Shut down 95111631-8f7f-46ed-a93a-8db1d01ae4e0:c26b2e31-d006-4d4d-9e56-45ca9391018d 2014-10-05 17:49:06 b.s.d.supervisor [INFO] Removing code for storm id production-topology-1-1412498729 2014-10-05 17:49:06 b.s.d.supervisor [INFO] Shutting down and clearing state for id 816a0fd6-7cdf-4312-a5ac-758f7f55ce46. Current supervisor time: 1412498946. State: :not-started, Heartbeat: nil 2014-10-05 17:49:06 b.s.d.supervisor [INFO] Shutting down 95111631-8f7f-46ed-a93a-8db1d01ae4e0:816a0fd6-7cdf-4312-a5ac-758f7f55ce46 2014-10-05 17:49:06 b.s.d.supervisor [INFO] Shut down 95111631-8f7f-46ed-a93a-8db1d01ae4e0:816a0fd6-7cdf-4312-a5ac-758f7f55ce46 2014-10-05 17:49:06 b.s.d.supervisor [INFO] Shutting down and clearing state for id c26b2e31-d006-4d4d-9e56-45ca9391018d. Current supervisor time: 1412498946. State: :not-started, Heartbeat: nil 2014-10-05 17:49:06 b.s.d.supervisor [INFO] Shutting down 95111631-8f7f-46ed-a93a-8db1d01ae4e0:c26b2e31-d006-4d4d-9e56-45ca9391018d 2014-10-05 17:49:06 b.s.d.supervisor [INFO] Shut down 95111631-8f7f-46ed-a93a-8db1d01ae4e0:c26b2e31-d006-4d4d-9e56-45ca9391018d ``` I use storm-starter example. ``` C:\apache-storm-0.9.2-incubating\examples\storm-starter>python ..\..\bin\storm j ar storm-starter-topologies-0.9.2-incubating.jar storm.starter.WordCountTopology production-topology remote ```
--- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---