请教大佬,使用savepoint的话最好是给每个算子设置一个唯一的uid吧?
那么问题就来了,我的程序里面算子太多了,每个都要设置一个uid吗?
那代码会相当冗余,给每个uid命名也是一个头疼的问题。比如下面的代码:
val stream = env.addSource(...).uid(...)
.filter(...).uid(...)
.map(...).uid(...)
.map(...).uid(...)
.map(...).uid(...)
.filter(...).uid(...)
.map(...).uid(...)
.filter(...).uid(...)
.map(...).uid(...)
.assignTimestampsAndWatermarks(...).uid(...)


请问该如何做比较好?




--

kingdomad

回复