You need to enable JavaScript to run this app.
导航
使用指引
最近更新时间:2023.07.21 17:25:16首次发布时间:2022.11.11 17:16:16

流式计算 Flink 版支持开发 Flink SQL 和 Flink JAR 两种任务类型,请根据实际需求选择开发的任务类型。SQL 和 JAR 类型任务在开发过程中存在差异,请查看对应文档。

文档

说明

指导在控制台上如何创建、开发任务。

调试SQL作业

任务开发完成后,可以调试任务,规避数据风险,提升开发效率。
您可以选择在 Session 资源池中使用线上数据调试;也可以选择上传本地 CSV 数据文件进行离线调试。

配置 Flink 参数

指导如何配置 Flink 相关参数,包括 Task Manager 和 Job Manager 使用资源配置,以及 Checkpoint 、Task 故障重启策略、依赖文件等配置。

上线SQL作业

任务开发人员在完成开发、调试工作后,可以将任务上上线到生产环境。后续将由运维人员正式启动任务,任务便会持续执行并输出计算结果。

配置上下游信息

您可以为任务配置数据来源和数据去向,后续可在任务详情中查看任务中的数据来源。

变更引擎版本

目前主要支持 Flink 1.11-volcano 和 Flink 1.16-volcano 引擎版本。在 Flink SQL 场景中,两个版本之间支持自由切换。

管理作业版本

当任务上线后,系统将会记录任务版本,每操作一次则记录一次版本。
在任务版本页面,您可以对比当前版本和历史版本的差异、回滚历史版本、删除历史版本。