发表于 |
字数统计: 87 | 阅读时长 ≈ 1

所有operator中的初始化如果写在构造函数当中就会出错，问题是序列化时的问题
flink从jobmanager序列化到各个 taskmanager时可能会出问题

split组件功能可以减少多个flatmap的性能损失
多个flatmap数据每个都是使用全部的流进行filter
split一个就可以满足