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 <[email protected]>
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 <[email protected]>
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 <[email protected]>
Date: 2015-02-09T05:23:23Z
STORM-657:make the shutdown-worker sleep time before kill -9 configurable
----
---
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 [email protected] or file a JIRA ticket
with INFRA.
---
