·在业务上规避这类问题:单独处理热点的数据。
·Key的设计上:把热key进行拆分,如:北京按照地区进行拆分聚合。
·参数设置:Flink 1.9.0 SQL性能优化中升级了微批模型(MiniBatch)。原理是缓存一定的数据后再触发处理,减少对状态访问并提升吞吐量,减少数据的输出量。
标签:
笔试题
刷题
简历模板
AI算法
大数据
内推
内推: