Apache Flink 中文用户邮件列表
Search
everywhere
only in this topic
Advanced Search
Flink 1.12 Sql设置job name
Classic
List
Threaded
♦
♦
Locked
1 message
HideOnBushKi
Reply
|
Threaded
Open this post in threaded view
♦
♦
|
Flink 1.12 Sql设置job name
Hi 大佬们:
请教两个问题
tEnv.executeSql("sql1")
tEnv.executeSql("sql2")
1.executeSql中,两个作业似乎被分配到了不同的yarn appId中运行,如果这两个作业共同依赖一个kakfa
table,这会影响到消费位置吗?还是说 这两个appID其实是一个作业
2.怎么在1.12 SQL中设置 job name呢
--
Sent from:
http://apache-flink.147419.n8.nabble.com/
Free forum by Nabble
Edit this page