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
相关文章
相关标签/搜索