[ https://issues.apache.org/jira/browse/STORM-657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311811#comment-14311811 ]
ASF GitHub Bot commented on STORM-657: -------------------------------------- GitHub user caofangkun opened a pull request: https://github.com/apache/storm/pull/421 STORM-657:make the shutdown-worker sleep time before kill -9 configurable * add config ``` $vim $STORM_CONF_DIR/storm.yaml supervisor.worker.shutdown.sleep.secs: 5 ``` * Restart Supervisor Process. * submit topology ``` $ storm jar storm-starter-0.10.0-SNAPSHOT.jar storm.starter.ExclamationTopology ExclamationTopology ``` * Kill Topology ``` $ storm kill ExclamationTopology ``` * check the log ``` $ tail -100f supervisor.log 2015-02-09T13:17:34.043+0800 b.s.config [INFO] GET worker-user 6028cc32-f617-40f5-b0fc-1571481d38ec 2015-02-09T13:17:34.054+0800 b.s.d.supervisor [INFO] Sleep 5 seconds for execution of cleanup threads on worker. 2015-02-09T13:17:35.426+0800 b.s.d.supervisor [INFO] Worker Process 6028cc32-f617-40f5-b0fc-1571481d38ec exited with code: 20 2015-02-09T13:17:39.069+0800 b.s.util [INFO] Error when trying to kill 12583. Process is probably already dead. 2015-02-09T13:17:39.077+0800 b.s.config [INFO] REMOVE worker-user 6028cc32-f617-40f5-b0fc-1571481d38ec 2015-02-09T13:17:39.078+0800 b.s.d.supervisor [INFO] Shut down d794f4df-d8e7-46f6-9bad-7698308f4d83:6028cc32-f617-40f5-b0fc-1571481d38ec 2015-02-09T13:17:39.079+0800 b.s.d.supervisor [INFO] Shutting down and clearing state for id d1da554d-3da4-480f-bad7-64c2c00c7d09. Current supervisor time: 1423459048. State: :disallowed, Heartbeat: #backtype.storm.daemon.common.WorkerHeartbeat{:time-secs 1423459048, :storm-id "ExclamationTopology-3-1423458925", :executors #{[7 7] [1 1] [-1 -1] [16 16] [13 13] [10 10] [4 4]}, :port 6700} 2015-02-09T13:17:39.079+0800 b.s.d.supervisor [INFO] Shutting down d794f4df-d8e7-46f6-9bad-7698308f4d83:d1da554d-3da4-480f-bad7-64c2c00c7d09 ``` You can merge this pull request into a Git repository by running: $ git pull https://github.com/caofangkun/apache-storm storm-657 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/storm/pull/421.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #421 ---- commit 6c04e1bea802d28ae92a234ddbaad2c1ed0a6835 Author: caofangkun <caofang...@gmail.com> Date: 2015-01-23T01:28:46Z Merge pull request #4 from apache/master Merger from apache/storm to caofangkun/apache-storm commit d8c98cb1846bd07aef558bde410607b923aa5c1e Author: caofangkun <caofang...@gmail.com> Date: 2015-02-04T01:09:22Z Merge pull request #5 from apache/master Merge from apache/storm to caofangkun/apache-storm commit b1c993b288385f637fa26b840a11532c7b60a6c7 Author: caofangkun <caofang...@gmail.com> Date: 2015-02-09T05:23:23Z STORM-657:make the shutdown-worker sleep time before kill -9 configurable ---- > make the shutdown-worker sleep time before kill -9 configurable > --------------------------------------------------------------- > > Key: STORM-657 > URL: https://issues.apache.org/jira/browse/STORM-657 > Project: Apache Storm > Issue Type: Improvement > Affects Versions: 0.9.2-incubating > Reporter: Vincent Russell > Priority: Minor > Fix For: 0.9.2-incubating > > > This is a continuation of STORM-183: Supervisor/worker shutdown hook should > be called in distributed mode. > It would be nice to be able to configure how many seconds (or millis) to > sleep for before shutting down the worker process in the shutdown-worker > function in supervisor.clj -- This message was sent by Atlassian JIRA (v6.3.4#6332)