Flink 使用Memory State致使OOM問題與解決

1、現象html 1.1 程序現象linux 程序是處理一個業務由2個表、4條數據、互相Join造成2條結果。Flink讀取Kafka。模擬數據程序持續往Kafka插入數據,在TaskManager只有較低內存時，模擬了2000次插入（8000條數據時）,Flink的TaskManager就發生了OOM問題。使用jstat -gcutil （遇到一個小問題root用戶沒法查看yarn用戶的jvm

>>阅读原文<<