hi
你需要去掉 `getCheckpointBackend()`
Best,
Congxian
hdxg1101300...@163.com 于2020年5月21日周四 下午4:24写道:
> 我设置的是true 啊
>
> env.setStateBackend(
> new RocksDBStateBackend("hdfs://beh/user/dc_cbss/flink5/checkpoints" ,
> true)
> .getCheckpointBackend()
> );
>
>
> hdxg1101300...@163.com
>
> 发件人: Congxian
我设置的是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
从错误栈看,使用的是 HeapStateBackend,所以肯定不是