在哪里更改SleepSpoutWaitsTrateTime的值

9q78igpj 于 2021-06-24 发布在 Storm

关注(0)|答案(3)|浏览(324)

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

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中找不到这样的文件。
有人能帮忙吗？

apache-storm

来源：https://stackoverflow.com/questions/17420230/where-to-change-the-value-of-sleepspoutwaitstrategytime

3条答案

按热度按时间

6rvt4ljy1#

改变 topology.sleep.spout.wait.strategy.time.ms 属性位于 $STORM_ROOT_DIR/conf 目录
但是我在eclipse中找不到这样的文件。
它应该包括在风暴的jar里。。。例如，如果您正在使用 0.9.0-wip21 然后在“storm-core-0.9.0-wip21.jar”下找到default.yaml文件

赞(0）回复(0）举报 2021-06-24

nom7f22z2#

您可以在 storm.yaml 文件。 default.yaml 只是默认值 storm.yaml 用于在不重写默认值时提供默认值的文件。

赞(0）回复(0）举报 2021-06-24

rhfm7lfc3#

... conf.put（config.topology\u sleep\u spout\u wait\u strategy\u time\u ms，1000）。。。cluster.submittopology（“xyz”，conf，buildtopology（））；

赞(0）回复(0）举报 2021-06-24