You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by 小昌同学 <cc...@163.com> on 2023/04/14 08:26:35 UTC
flink sink web ui显示为Sink: Unnamed
我将流式数据输出到mysql，查看flink 自带的web ui界面，有一个sink节点显示为Sink: Unnamed ，这个针对sink节点可以命名嘛
| |
小昌同学
|
|
ccc0606fighting@163.com
|
回复：flink sink web ui显示为Sink: Unnamed
Posted by 小昌同学 <cc...@163.com>.
好滴，谢谢各位老师
| |
小昌同学
|
|
ccc0606fighting@163.com
|
---- 回复的原邮件 ----
| 发件人 | hjw<hj...@163.com> |
| 发送日期 | 2023年4月14日 16:38 |
| 收件人 | <us...@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，"小昌同学" <cc...@163.com> 写道：
我将流式数据输出到mysql，查看flink 自带的web ui界面，有一个sink节点显示为Sink: Unnamed ，这个针对sink节点可以命名嘛
| |
小昌同学
|
|
ccc0606fighting@163.com
|
Re:flink sink web ui显示为Sink: Unnamed
Posted by hjw <hj...@163.com>.
可以在算子后面调用.name()方法指定名称，方法参数就是算子名称。
比如需sink的流为stream
stream.sinkTo(Sink算子).name("sink-name")
--
Best，
Hjw
在 2023-04-14 16:26:35，"小昌同学" <cc...@163.com> 写道：
>我将流式数据输出到mysql，查看flink 自带的web ui界面，有一个sink节点显示为Sink: Unnamed ，这个针对sink节点可以命名嘛
>
>
>| |
>小昌同学
>|
>|
>ccc0606fighting@163.com
>|
Re: flink sink web ui显示为Sink: Unnamed
Posted by Weihua Hu <hu...@gmail.com>.
可以，在算子后可以通过 .name("xxx") 来命名
Best,
Weihua
On Fri, Apr 14, 2023 at 4:27 PM 小昌同学 <cc...@163.com> wrote:
> 我将流式数据输出到mysql，查看flink 自带的web ui界面，有一个sink节点显示为Sink: Unnamed
> ，这个针对sink节点可以命名嘛
>
>
> | |
> 小昌同学
> |
> |
> ccc0606fighting@163.com
> |