从你提供的图片来看,Flink CDC to Doris 的并行度可以从以下两个维度进行调整:
1. Source 并行度
Source 并行度是指 Flink CDC 读取数据源(如 MySQL)的并行度,可以从 Source properties 中的 scan.並行度
参数进行调整。
2. Sink 并行度
Sink 并行度是指 Flink CDC 写入数据接收器(如 Doris)的并行度,可以从 Sink properties 中的 sink.並行度
参数进行调整。
一般来说,Source 并行度和 Sink 并行度应该设置为相同的值,以确保数据处理速度和写入性能的均衡。
最佳实践:
注意:
具体到你的图片示例中:
图片中显示的 Flink CDC to Doris 的并行度均设置为 4
,这表明 Source 并行度和 Sink 并行度都设置为 4
。这是一种常见的并行度设置,适合于中等规模的数据量和处理能力。
如果你需要调整并行度,可以根据实际情况修改 Source properties 和 Sink properties 中的 並行度
参数。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。