请教大佬,使用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
