在一台机器上 apache-storm-xxx/logs/work-fxxx/{topology启动批次号}/{用于当前topology的worker jvm的端口号}/
当然这个worker 一个worker服务于一个topology
看worker.log
里面有spout线程和bolt线程:
里面可以搜到
Thread-{no}-{bolt_tag or spout_tag}-executor
这个worker下面有几个线程是固定的,可以通过grep这个来匹配,同一个线程内发生的事情
spout或者bolt名字,这在stormui上都可以看到
spout-xxx
b-0
b-1
b-2
....
一般spout线程数数量要等于 kafka相应topic下partition数量
spout线程数除以worker数量可以算出一个worker里面有多少spout线程,bolt也是同理
网友评论