开发者社区 问答 正文

在统一FLINK Application中(一个main class)用FLINK Kafka C

在统一FLINK Application中(一个main class)用FLINK Kafka SQL Connector 都多个Kafka TOPIC, 然后对每一个Kafka Table, 取出一些字段后, insert后续Kafka Table。

任务提交到Yarn后, 为什么每一个SQL语句都会启动一个JobManager? 甚至都一个Kafka Source Table, SINK两次的话, 每一个SINK都是一个独立的Job?

是我的用户不对吗? 请各位指教。

展开
收起
游客kpgrmhlkg4uoy 2021-01-10 17:45:23 555 分享
分享
版权
举报
0 条回答
写回答
取消 提交回答