好滴,谢谢各位老师

| |
小昌同学
|
|
[email protected]
|
---- 回复的原邮件 ----
| 发件人 | hjw<[email protected]> |
| 发送日期 | 2023年4月14日 16:38 |
| 收件人 | <[email protected]> |
| 主题 | Re:flink sink web ui显示为Sink: Unnamed |
可以在算子后面调用.name()方法指定名称,方法参数就是算子名称。
比如需sink的流为stream
stream.sinkTo(Sink算子).name("sink-name")




--

Best,
Hjw





在 2023-04-14 16:26:35,"小昌同学" <[email protected]> 写道:
我将流式数据输出到mysql,查看flink 自带的web ui界面,有一个sink节点显示为Sink: Unnamed ,这个针对sink节点可以命名嘛


| |
小昌同学
|
|
[email protected]
|

回复