请教设置uid的最佳实践

[kingdomad <ki...@163.com>]

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

回复：请教设置uid的最佳实践

[flink小猪 <18...@163.com>]

你这里绝大多数都不用设置吧


| |
18579099920
|
|
邮箱：18579099920@163.com
|

签名由 网易邮箱大师 定制

在2020年11月26日 12:09，范瑞 写道：
无状态算子可以不设置


Best
fanrui



---原始邮件---
发件人: "kingdomad"<kingdomad@163.com&gt;
发送时间: 2020年11月26日(周四) 中午11:58
收件人: "user-zh"<user-zh@flink.apache.org&gt;;
主题: 请教设置uid的最佳实践


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

回复：请教设置uid的最佳实践

[范瑞 <83...@qq.com>]

无状态算子可以不设置


Best
fanrui



---原始邮件---
发件人: "kingdomad"<kingdomad@163.com&gt;
发送时间: 2020年11月26日(周四) 中午11:58
收件人: "user-zh"<user-zh@flink.apache.org&gt;;
主题: 请教设置uid的最佳实践


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