在哪里可以找到这个风暴可配置`topology.worker.timeout.secs`的默认值？

Question

我在这里找到声明：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)中找到它的默认值。我试图在我的设置中调优这个参数，但是需要弄清楚什么是“推荐的”值。

Answer 1

关于topology.worker.timeout.secs的评论说：

拓扑，可配置工作者心跳超时，然后主管尝试重新启动工作进程。最大值受WORKER_MAX_TIMEOUT_SECS约束。当拓扑超时更大时，会有效地覆盖以下信任：SUPERVISOR_WORKER_TIMEOUT_SECS、SUPERVISOR_WORKER_START_TIMEOUT_SECS、NIMBUS_TASK_TIMEOUT_SECS和NIMBUS_TASK_LAUNCH_SECS。

由于我也找不到默认值，所以我查看了nimbus.java

if (mergedConf.containsKey(Config.TOPOLOGY_WORKER_TIMEOUT_SECS)) {
  int workerTimeoutSecs = (Integer) ObjectReader.getInt(mergedConf.get(Config.TOPOLOGY_WORKER_TIMEOUT_SECS));
  int workerMaxTimeoutSecs = (Integer) ObjectReader.getInt(mergedConf.get(Config.WORKER_MAX_TIMEOUT_SECS));
  if (workerTimeoutSecs > workerMaxTimeoutSecs) {
      ret.put(Config.TOPOLOGY_WORKER_TIMEOUT_SECS, workerMaxTimeoutSecs);
      ...
  }
}

但是这个键并不包含在任何地方，而且当我通过nimbus调试并计算这个配置时，我得到了null，这意味着这个值永远不会被设置。

在WORKER_MAX_TIMEOUT_SECS default.yaml**，中，查看的时间为600秒，因此我认为这可能是您的起点。