FlinkFlink RocksDBListState getInternal 状态太大 导致OOM Java heap space

Posted 九师兄

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了FlinkFlink RocksDBListState getInternal 状态太大 导致OOM Java heap space相关的知识,希望对你有一定的参考价值。


20220910 01:03 睡不着了,想着今天晚上一个小时重新撸了一遍开发了2个月的代码,重写了一遍。然后到家后发现又失眠了,最近总是容易失眠,九师兄干脆起来学习。

1.概述

FLink使用RocksDBListState 这个内存溢出,是不是这个窗口里面的数据太多了导致的?


根据报错找到报错位置

    @Override
    public Iterable<V> get() 
   
        

以上是关于FlinkFlink RocksDBListState getInternal 状态太大 导致OOM Java heap space的主要内容,如果未能解决你的问题,请参考以下文章

FlinkFlink 源码之快照

FlinkFlink 1.13 编译

FlinkFlink PipelineExecutor 体系

FlinkFlink Max 和 MaxBy的区别

FlinkFlink 学习的示例

FlinkFLink 通讯组件 RPC