如何更改SleepSpoutWaitStrategyTime的值

2013-07-02 244 views 3 likes

我正在使用风暴...我想将topology.sleep.spout.wait.strategy.time.ms的时间从1毫秒（默认）增加到1秒。但我不知道它在哪里。我有它的定义如下如何更改SleepSpoutWaitStrategyTime的值

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中找到这样的文件。

有人可以帮忙吗？

2013-07-02 Ezhil

回答

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

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

2013-07-03 02:09:55

... conf.put（Config.TOPOLOGY_SLEEP_SPOUT_WAIT_STRATEGY_TIME_MS，1000）; ... cluster.submitTopology（“xyz”，conf，buildTopology（））;

2014-03-27 15:12:27

变化topology.sleep.spout.wait.strategy.time.ms财产风暴default.yaml文件地处$STORM_ROOT_DIR/conf DIR

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

应列入风暴的罐子......因为如果你使用的是0.9.0-wip21分布则default.yaml文件应该在'下找到例子风暴核心0.9.0-wip21.jar

2014-03-28 06:05:49 user2720864