3

我正在使用风暴...我想将时间topology.sleep.spout.wait.strategy.time.ms从 1 毫秒（默认）增加到 1 秒。但我不知道这是在哪里。我有一个配置类，它的定义如下

public static final String TOPOLOGY_SLEEP_SPOUT_WAIT_STRATEGY_TIME_MS="topology.sleep.spout.wait.strategy.time.ms";

我想将此字段包含在其类为的 bean 下backtype.storm.config

我应该使用什么参数名称？是emptyEmit吗？

编辑：我搜索了网络，并指定这些值将出现在 中default.yaml，但我在 Eclipse 中找不到这样的文件。

有人可以帮忙吗？

4

3 回答 3

3

... conf.put(Config.TOPOLOGY_SLEEP_SPOUT_WAIT_STRATEGY_TIME_MS, 1000); ... cluster.submitTopology("xyz", conf, buildTopology());

于 2014-03-27T15:12:27.530 回答
2

更改topology.sleep.spout.wait.strategy.time.ms位于$STORM_ROOT_DIR/conf目录中的风暴 default.yaml 文件中的属性

但我在 Eclipse 中找不到这样的文件。

它应该包含在storm的jar中......例如，如果您使用的是0.9.0-wip21分发，那么default.yaml文件应该在`storm-core-0.9.0-wip21.jar下找到

于 2014-03-28T06:05:49.010 回答
1

storm.yaml您可以在文件中指定它。

default.yaml只是一个默认storm.yaml文件，用于在您不覆盖它们时提供默认值。

于 2013-07-03T02:09:55.657 回答