详细教程 | 如何使用 DolphinScheduler 调度 Flink 实时任务
Apache DolphinScheduler 非常适用于实时数据处理场景，尤其是与 Apache Flink 的集成。DolphinScheduler 提供了丰富的功能，包括任务依赖管理、动态调度、实时监控和日志管理，能够有效简化 Flink 实时任务的管理和部署。通过 DolphinScheduler 的可视化界面，用户可以轻松创建和配置 Flink 任务，设置任务的调度规则，并实时监控任务的执行状态，帮助企业高效地处理大规模实时数据，提升数据处理的效率和可靠性。
本文将详细演示如何使用 Apache DolphinScheduler 调度 Flink 实时任务。
在“项目管理”>>"工作流定义" 里边创建工作流
选择 flink_stream
选择安装 flink 服务的节点 worker 分组 程序类型选择 sql
在“脚本” 编写框输入 flink-sql 主代码
选择 flink 版本，指定任务名称，配置资源参数 最后点击确认保存
在任务定义>> 实时任务列表找到刚才编写的 flink_stream 任务流，点击执行
一家开源原生的DataOps商业公司。 2022-03-18 加入
致力于打造下一代开源原生的DataOps 平台，助力企业在大数据和云时代，智能化地完成多数据源、多云及信创环境的数据集成、调度开发和治理，以提高企业解决数据问题的效率，提升企业分析洞察能力和决策能力。
评论