使用fluxyaml,如何在storm拓扑中提到螺栓的任务数?

qlfbtfca  于 2021-06-24  发布在  Storm
关注(0)|答案(0)|浏览(259)

请参见storm flux yaml的以下片段:


## spout definitions

spouts: 

# spouts- Start

  - id: "perform-spout"
    className: "org.apache.storm.kafka.KafkaSpout"
    parallelism: 2
    constructorArgs:
      - ref: "PerformSpoutConfig"

# spouts- End

## bolt definitions

bolts: 

# bolt - Start

  - id: "perform-bolt"
    className: "com.cc.adv.asp.test.KafkaPerformanceBolt"
    parallelism: 2      

# bolt - End

使用此脚本,storm ui将显示执行者数量=任务数量。请建议如何指定flux yamls中的任务数?提前谢谢。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题