禁止operator chaining
- 用dataStream.disableChaining()防止前一个和后一个operator被合并到一起
- 用StreamExecutionEnvironment.disableOperatorChaining()可以关掉全局的chaining。
出于performance考虑，禁止operator chaining只用于debug！chaining可以让上下游operator共用线程，减少线程切换。
**
2020-01-11
Flink任务原来的构造：
从Kafka接收pingback -> 过滤+解析 -> 写Hbase
问题：
总是反压，且checkpoint无法完成
原因：
写Hbase的部分跟不上前面解析的速度。
解决：
将解析后的数据发送到Kafka，然后单独一个任务接收这个Kafka的消息，写Hbase
若有收获，就点个赞吧
0 人点赞
