如何优雅的开发Flink SQL作业

[HideOnBushKi]

大佬们好，现在业务需求多，生产作业开始变得繁重，请教3个生产业务场景，主要是想看下各位有什么优雅的思路

1.kakfa table和group_ID应该怎么去维护呢？一个业务一张表吗？
2.如何做到复用表的效果？
3.如果新增一个业务需求，用到之前的一张kafka table，似乎要在一个程序里。执行多次 executeSql("sql
1")才不会乱序，但是这样的话，程序的耦合度会很高，请问该怎么优雅的处理这些场景呢？



--
Sent from: http://apache-flink.147419.n8.nabble.com/

[nobleyd]

1 kafka table和group id是啥意思。group id随意写一个就可以了。
2 本身就可以复用。
3 听不懂表达啥。


HideOnBushKi <[hidden email]> 于2021年1月4日周一 下午3:43写道：

> 大佬们好，现在业务需求多，生产作业开始变得繁重，请教3个生产业务场景，主要是想看下各位有什么优雅的思路
>
> 1.kakfa table和group_ID应该怎么去维护呢？一个业务一张表吗？
> 2.如何做到复用表的效果？
> 3.如果新增一个业务需求，用到之前的一张kafka table，似乎要在一个程序里。执行多次 executeSql("sql
> 1")才不会乱序，但是这样的话，程序的耦合度会很高，请问该怎么优雅的处理这些场景呢？
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/