开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

Flink CDC中怎么通过rest api接口提交一个flink任务?

Flink CDC中怎么通过rest api接口提交一个flink任务?

展开
收起
cuicuicuic 2023-05-09 13:40:27 216 0
1 条回答
写回答
取消 提交回答
  • 存在即是合理

    Flink CDC提供了一个REST API接口,可以用于提交Flink任务。参考步骤:

    1、确认Flink环境已经正确地配置和启动了。需要确保已经拥有一个可用的Flink集群,并且已经将CDC源集成到了该集群中。

    2、打开浏览器并访问Flink CDC的REST API接口。默认情况下,该接口位于http://localhost:8083/flink-rest/ 。

    3、在API接口中输入必要的参数来创建一个新的Flink任务。这些参数包括:

    1.Task name:任务名称。
    
    2.Job name:作业名称。
    
    3.Configuration:任务的配置信息,包括所需的资源、数据源等。
    
    4.Input data:输入数据的位置和格式。
    
    5.Output data:输出数据的位置和格式。
    
    6.Execution settings:执行设置,包括并行度、调度策略等。
    

    4、点击“Submit”按钮来提交任务。Flink CDC将自动启动任务并开始处理数据流。

    另外提交任务之前,需要确保Flink集群有足够的资源来运行该任务。

    2023-05-09 17:16:17
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载