flink1.9.1单任务配置rocksDB不生效怎么办？
Hi，想请教大家一个问题，我用单任务配置使用rocksDB状态后端，代码如下：
val backend = new RocksDBStateBackend(path, true) backend.setPredefinedOptions(PredefinedOptions.SPINNING_DISK_OPTIMIZED) env.setStateBackend(backend.asInstanceOf[StateBackend])
但是运行代码后，去webui查看Job Manager --> Configuration 中查看，发现state.backend还是显示filesystem
这是说明我的配置没有生效嘛？如果没有生效，那么如何进行单任务配置rocksDB呢？*来自志愿者整理的flink邮件归档
展开
收起
1
条回答
写回答
写回答
-
state.backend 应该是你在 flink-conf 中设置了这个值。具体到你这里的情况，最终的配置是
RocksDB（以代码为准，如果代码没有设置会使用 flink-conf 中的文件）。你可以看看 TM 日志，应该可以看到更详细的信息
*来自志愿者整理的FLINK邮件归档
2021-12-02 14:16:03赞同 展开评论 打赏
问答分类：
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
