这是一个创建于 568 天前的主题，其中的信息可能已经有所发展或是发生改变。
目前是要做一个数据传输服务，需要根据页面提交的配置将数据从一个数据源同步到另一个数据源。数据源可能是关系型数据库，也可能是消息队列，或者 Hive 。
了解了下 Flink 发现有两种提交 job 的方式：
- 将程序打包成 jar 文件提交给 flink 去执行
- 以 flink run 的形式执行 flink sql
疑问是客户端运行时要怎么根据配置信息动态生成 flink job ，并远程提交给 flink 去执行？
 |
1
wangyiyi10 2023-06-09 10:37:28 +08:00  1
创建 remote env 。
可以参考一下 Zeppelin 支持 Flink 的逻辑 |
 |
2
sijue 2023-06-09 11:52:58 +08:00
Akka Actor System 通信系统了解一下
|
 |
3
ttskym 2023-06-09 12:53:49 +08:00
一条流里做，还是多条流做？
|
Select Language