找到原因了,代码在提交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
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: