3

私は嵐を使用しています... 時間をtopology.sleep.spout.wait.strategy.time.ms1 ミリ秒 (デフォルト) から 1 秒に増やしたいです。しかし、これがどこにあるのかわかりません。次のように定義されている構成クラスがあります

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

クラスが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ディレクトリにあるストームの default.yaml ファイルのプロパティを$STORM_ROOT_DIR/conf変更します

しかし、Eclipseでそのようなファイルを見つけることができませんでした。

これは、ストームの jar に含まれている必要があります。たとえば、0.9.0-wip21ディストリビューションを使用している場合、default.yaml ファイルは「storm-core-0.9.0-wip21.jar」の下にあります。

于 2014-03-28T06:05:49.010 に答える
1

ファイルで指定できますstorm.yaml。

default.yamlstorm.yamlオーバーライドしない場合にデフォルト値を提供するために使用される単なるデフォルトファイルです。

于 2013-07-03T02:09:55.657 に答える