Flink 1.12 Sql设置job name

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

Flink 1.12 Sql设置job name

HideOnBushKi
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/