有很多地址可以调,比如直接内存配比、内存管理器glibc参数、taskmanager、jobmanager内存大小、状态配置、等等 详见:https://nightlies.apache.org/flink/flink-docs-release-1.13/docs/deployment/config/
比如:
table.exec.source.cdc-events-duplicate = true
state.backend = rocksdb
state.backend.incremental = true
state.checkpoints.dir = hdfs:///user/flink/{notebook}
execution.checkpointing.unaligned = true
execution.checkpointing.interval = 300000
execution.checkpointing.min-pause = 60000
execution.checkpointing.max-concurrent-checkpoints = 1
execution.checkpointing.tolerable-failed-checkpoints = 1
execution.checkpointing.externalized-checkpoint-retention = RETAIN_ON_CANCELLATION
taskmanager.numberOfTaskSlots = 2
jobmanager.memory.process.size = 2048m
taskmanager.memory.process.size = 4096m
taskmanager.memory.managed.fraction = 0.6
需要登录实时计算管理控制台,然后在Flink全托管页签,单击目标工作空间操作列下的控制台,在自动调优页签,单击配置,可以根据自己需求配置。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。