Flink最佳实践
更新时间 2026-10-12 11:43:54
最近更新时间: 2026-10-12 11:43:54
本章节介绍Flink最佳实践。
作业开发
新建作业时优先明确运行模式、输入源、输出端、状态规模、延迟目标和容错要求。对于 SQL 能表达的实时计算和数据集成场景,优先使用 SQLAPI方式提交作业;如您需要使用复杂状态逻辑或自定义事件处理时,推荐您考虑 DataStream API。
注意
连接器 JAR、用户 JAR 和配置文件应统一管理,避免不同作业使用不一致的依赖版本。
生产运行
对于生产集群的流式生产作业建议您开启 Checkpoint,并使用可靠存储保存 Checkpoint 和 Savepoint。作业升级、参数变更或依赖变更前,建议先停止并生成 Savepoint,再从 Savepoint 恢复。对于需要访问安全组件的作业,应确认作业能获取相关有效认证凭据。对于高吞吐写入场景,应同步评估目标端承载能力,避免目标端成为瓶颈导致作业写入阻塞或异常。
配置管理
请您参考Flink性能调优章节,对Flink作业配置进行管理与优化。