stream Grouping,你在测试的时候测的是线程Thread id,所以分配的是线程,而不是Task?

来源:8-4 -FieldGrouping开发详解

BingleyFeng

2018-07-12

写回答

1回答

Michael_PK

2018-07-13

task都是跑在thread上

0
0

Java大数据实战,巧用Storm快速切入实时流处理领域

深入Storm内部机制,logstash+kafka,快速切入大数据实时流处理

518 学习 · 143 问题

查看课程