请参见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中的任务数?提前谢谢。
暂无答案!
目前还没有任何答案,快来回答吧!