退订

2022-04-08 Thread swessia

Re:Re: rocksdb backend设置后没有启用

2022-02-27 Thread swessia
找到原因了,代码在提交job时读取了本地老的配置文件,使得state backend配置覆盖了集群配置 感谢大佬 在 2022-02-25 17:09:09,"胡伟华" 写道: >Hi, swessia > >flink-conf 中的 state.backend 是集群默认配置,你可以检查下 Job 是否指定了backend。 >具体方式可以参考官方文档: >https://nightlies.apache.org/flink/flink-docs-master/docs/ops/state/state_back

rocksdb backend设置后没有启用

2022-02-22 Thread swessia
flink版本:1.13.5 flink-conf.yml中的rocksdb配置: taskmanager.memory.process.size: 2048m taskmanager.memory.managed.fraction: 0.15 taskmanager.memory.network.fraction: 0.1 state.backend: rocksdb state.backend.incremental: true state.checkpoints.dir: