Hi 大佬们:
请问怎么在1.12Flink sql 中设置job name呢
--
Sent from: http://apache-flink.147419.n8.nabble.com/
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/
我猜测,要是可以在invoke的时候,拿到sink当前对应的barriar的话,从这个barriar取出offset,或者在richSinkFunction时,调用getRuntimeContext()上下文对象,从这个上下文中,拿到当前的task
metrics,从而取出task的offset
--
Sent from: http://apache-flink.147419.n8.nabble.com/
大佬们好,现在业务需求多,生产作业开始变得繁重,请教3个生产业务场景,主要是想看下各位有什么优雅的思路
1.kakfa table和group_ID应该怎么去维护呢?一个业务一张表吗?
2.如何做到复用表的效果?
3.如果新增一个业务需求,用到之前的一张kafka table,似乎要在一个程序里。执行多次 executeSql("sql
1")才不会乱序,但是这样的话,程序的耦合度会很高,请问该怎么优雅的处理这些场景呢?
--
Sent from: http://apache-flink.147419.n8.nabble.com/