关于 Flink 做数据传输的疑问

查看 36|回复 1
作者:7911364440   
目前是要做一个数据传输服务,需要根据页面提交的配置将数据从一个数据源同步到另一个数据源。数据源可能是关系型数据库,也可能是消息队列,或者 Hive 。
了解了下 Flink 发现有两种提交 job 的方式:
  • 将程序打包成 jar 文件提交给 flink 去执行
  • 以 flink run 的形式执行 flink sql

    疑问是客户端运行时要怎么根据配置信息动态生成 flink job ,并远程提交给 flink 去执行

    flink, 提交, 数据, job

  • wangyiyi10   
    创建 remote env 。
    可以参考一下 Zeppelin 支持 Flink 的逻辑
    您需要登录后才可以回帖 登录 | 立即注册

    返回顶部