Re: Re: 使用rocksdb backend 内存溢出的问题疑问

2020-05-21 文章 Congxian Qiu
hdxg1101300...@163.com > > 发件人: Congxian Qiu > 发送时间: 2020-05-21 15:58 > 收件人: user-zh > 主题: Re: 使用rocksdb backend 内存溢出的问题疑问 > Hi > 从错误栈看,使用的是 HeapStateBackend,所以肯定不是 RocksDBStateBackend > > 你把代码改成 `env.setStateBackend(new > RocksDBStateBackend("hdfs://beh

Re: Re: 使用rocksdb backend 内存溢出的问题疑问

2020-05-21 文章 hdxg1101300...@163.com
我设置的是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

Re: 使用rocksdb backend 内存溢出的问题疑问

2020-05-21 文章 Congxian Qiu
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写道: > 这是内存分析的截图 >