好滴,谢谢各位老师
| | 小昌同学 | | ccc0606fight...@163.com | ---- 回复的原邮件 ---- | 发件人 | hjw<hjw_em...@163.com> | | 发送日期 | 2023年4月14日 16:38 | | 收件人 | <user-zh@flink.apache.org> | | 主题 | Re:flink sink web ui显示为Sink: Unnamed | 可以在算子后面调用.name()方法指定名称,方法参数就是算子名称。 比如需sink的流为stream stream.sinkTo(Sink算子).name("sink-name") -- Best, Hjw 在 2023-04-14 16:26:35,"小昌同学" <ccc0606fight...@163.com> 写道: 我将流式数据输出到mysql,查看flink 自带的web ui界面,有一个sink节点显示为Sink: Unnamed ,这个针对sink节点可以命名嘛 | | 小昌同学 | | ccc0606fight...@163.com |