1. 首頁
  2. 問答
  3. 如何更改SleepSpoutWaitStrategyTime的值

如何更改SleepSpoutWaitStrategyTime的值

2013-07-02 299 views
3

我正在使用風暴...我想將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

回答

1

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

default.yaml只是一個默認的storm.yaml文件，用於在不覆蓋它們時提供默認值。

來源

2013-07-03 02:09:55

2

... conf.put（Config.TOPOLOGY_SLEEP_SPOUT_WAIT_STRATEGY_TIME_MS，1000）; ... cluster.submitTopology（「xyz」，conf，buildTopology（））;

來源

2014-03-27 15:12:27

2

變化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

相關問題

 相關問題