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

idea运行flink, 如何提交多个任务呀?

idea运行flink, 如何提交多个任务呀?

展开
收起
爱喝咖啡嘿 2022-12-27 14:35:00 334 0
1 条回答
写回答
取消 提交回答
  • 十分耕耘,一定会有一分收获!

    楼主你好,首先来看一下这个思路:flink内部都是将我们的算子去转换成StreamGraph,然后将StreamGraph转换为JobGraph,再将JobGraph提交到集群的。

    所以我们就是要想办法将我们的程序jar包转换为JobGraph,然后利用ClusterDescriptor的实现类去完成JobGraph的提交

    项目模块目前只需要两个,flink-deployer-common和flink-deployer-1.13

    common模块包含一些公共类 deployer模块是真正的针对不同部署模式的提交程序

    2022-12-28 07:58:56
    赞同 1 展开评论 打赏

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

相关产品

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

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