面试题十五

问题:Flink过来的数据量太大怎么处理?

解答:加机器,考虑使用处理时间(ProcessingTime),前面使用Kafka来做蓄水池,降低消费数据的速度。尽量使用滚动窗口,窗口没有重合,数据不会复制到不同的窗口中去。