我在这个flatmap里面是根据传入值得一个字段提取当成key，然后keyby这个字段，由于这个字段会变化，所以用了confStream这个配置流。目前得问题是我把flatmap并行度设为我指定的parallelism时，并没有达到我想将不同的key分配到不同的task的要求，但是设为1的话就可以达到，目前没有明白时为什么，请各位大牛解惑。
转自钉钉群21789141：我在这个flatmap里面是根据传入值得一个字段提取当成key，然后keyby这个字段，由于这个字段会变化，所以用了confStream这个配置流。目前得问题是我把flatmap并行度设为我指定的parallelism时，并没有达到我想将不同的key分配到不同的task的要求，但是设为1的话就可以达到，目前没有明白时为什么，请各位大牛解惑。
展开
收起
1
条回答
写回答
写回答
-
云邪
.connect(confStream.keyBy(...)).flatMap 试试这个。
A.connect(B).flatmap 是将 A 和 B 流以 round-robin 的网络传输方式发送给 flatmap 节点。 A.connect(B).keyBy(..).flatmap ，等同于 A.keyBy(...).connect(B.keyBy(...)).flatmap, 是将 A 和 B 以 keyby 的方式发送给 flatmap 节点。
A.connect(B.keyBy(...)).flatmap， 是将 B 以 keyby 的方式发送给 flatmap， A 以 rount-robin 的方式。2019-07-17 23:08:20赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
问答排行榜
最热
最新
推荐问答
