Storm 使用 Kryo庫對對象進行序列化,框架
flink 序列化優化/自定義數據類型(減小gc),對於不適用於本身的序列化框架的數據類型,會使用Kryo來進行序列化,並非全部的類型都與Kryo無縫鏈接tcp
flink 本身管理內存,、優化
storm 一條一條發送,吞吐量低,netty
flink 批量內存發送,內存片默認32KB,Flink把將要發送的數據序列化到內存片中,當內存片湊滿或者超時,將此內存片發送出去orm
flink 優化拓撲結構對象
flink利用netty 反壓(tcp 滑動窗口)內存
flink多種計算窗口序列化