Apache Storm Stream API 中的并行性

问题描述

使用 Storms Stream API，我目前正面临一种不合逻辑的行为 - 据我所知。

比如说，我正在使用一个简单的数据流，它的初始化方式如下：

Stream<DataTuple> stream = builder.newStream(myDataSource,myValuesMapper,5);

在 LocalCluster 上执行此流时没有任何进一步操作，Storm 告诉我，创建了 5 个 spout 和 5 个 Bolt。但是，如果我用 parallelism=1 初始化流并在之后更改它，如下所示：

Stream<DataTuple> stream = builder.newStream(source,valuesMapper,1);
stream.repartition(5);

然后我只得到1个喷口和1个螺栓。

所以我的问题是：

1. 螺栓从哪里来？我没有做进一步的处理。
2. 如果我对直接来自 spout 的流进行重新分区，为什么 spout 的数量没有改变？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）