apache-storm - 在哪里更改 SleepSpoutWaitStrategyTime 的值

Question

我正在使用 storm...我想将 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"; 

我想将这个字段包含在类为 backtype.storm.config

的 bean 下

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

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

有人可以帮忙吗？

Answer 1

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