hdxg1101300...@163.com
>
> 发件人: Congxian Qiu
> 发送时间: 2020-05-21 15:58
> 收件人: user-zh
> 主题: Re: 使用rocksdb backend 内存溢出的问题疑问
> Hi
> 从错误栈看,使用的是 HeapStateBackend,所以肯定不是 RocksDBStateBackend
>
> 你把代码改成 `env.setStateBackend(new
> RocksDBStateBackend("hdfs://beh
我设置的是true 啊
env.setStateBackend(
new RocksDBStateBackend("hdfs://beh/user/dc_cbss/flink5/checkpoints" , true)
.getCheckpointBackend()
);
hdxg1101300...@163.com
发件人: Congxian Qiu
发送时间: 2020-05-21 15:58
收件人: user-zh
主题: Re: 使用rocksdb backend 内存溢出的问题疑问
Hi
从错误栈看,使用的是 HeapStateBack
Hi
从错误栈看,使用的是 HeapStateBackend,所以肯定不是 RocksDBStateBackend
你把代码改成 `env.setStateBackend(new
RocksDBStateBackend("hdfs://beh/user/dc_cbss/flink5/checkpoints" , true));`
再尝试一下看看
Best,
Congxian
hdxg1101300...@163.com 于2020年5月21日周四 下午3:38写道:
> 这是内存分析的截图
>