我在这里找到声明:https://github.com/apache/storm/blob/3f96c249cbc17ce062491bfbb39d484e241ab168/storm-client/src/jvm/org/apache/storm/Config.java#L1161,但无法从yaml(https://github.com/apache/storm/blob/b6e7d0355e0397b8acc566961ed31279338998e1/conf/defaults.yaml)中找到它的默认值。我试图在我的设置中调优此参数,但需要弄清楚什么是“推荐”值开始。
1条答案
按热度按时间2lpgd9681#
The comment on
topology.worker.timeout.secs
says:Topology configurable worker heartbeat timeout before the supervisor tries to restart the worker process. Maximum value constrained by
WORKER_MAX_TIMEOUT_SECS
. When topology timeout is greater, the following configs are effectively overridden:SUPERVISOR_WORKER_TIMEOUT_SECS
,SUPERVISOR_WORKER_START_TIMEOUT_SECS
,NIMBUS_TASK_TIMEOUT_SECS
andNIMBUS_TASK_LAUNCH_SECS
.As I can not find a default value for that as well, I had a look into
nimbus.java
:But this key is not contained anywhere, and when I am debugging through nimbus and evaluate that config, I get
null
, meaning, that this value is never set.Looking at
WORKER_MAX_TIMEOUT_SECS
gives 600 seconds indefault.yaml
, so I think this might serve as a starting point for you.