回复： 如何快速定位拖慢速度的 operator

["Sun.Zhu" <17...@163.com>]

虽然chain在一起，但是可以通过metrics中看出来各个算子的各项指标的
| |
Sun.Zhu
|
|
17626017841@163.com
|
签名由网易邮箱大师定制


在2020年06月25日 00:51，徐骁<ff...@gmail.com> 写道：
两个方法确实可以, 但是要追踪起来很废时间, 对小白太不友好啊

回复: 如何快速定位拖慢速度的 operator

["aven.wu" <da...@163.com>]

如果算子都在一个group里面的话确实在webui上不好看出背压问题，可以将operator chain 拆开。

• StreamExecutionEnvironment.disableOperatorChaining()：关闭整个Job的OperatorChain
• someStream.filter(...).map(...).startNewChain().map()：startNewChain()是指从当前Operator[map]开始一个新的chain，即：两个map会chaining在一起而filter不会（因为startNewChain的存在使得第一次map与filter断开了chain）。
• someStream.map(...).disableChaining()：disableChaining()是指当前Operator[map]禁用OperatorChain，即：Operator[map]会独自占用一个Task。
• someStream.map(...).slotSharingGroup("name")：默认情况下所有Operator的slotGroup都为default，可以通过slotSharingGroup()进行自定义，Flink会将拥有相同slotGroup名称的Operators运行在相同Slot内，不同slotGroup名称的Operators运行在其他Slot内。
希望对你有帮助

Best
Aven

发件人: 徐骁
发送时间: 2020年6月28日 10:16
主题: Re: 如何快速定位拖慢速度的 operator

好的 感谢两位我试试

Sun.Zhu <17...@163.com> 于2020年6月25日周四 下午11:19写道：

> 虽然chain在一起，但是可以通过metrics中看出来各个算子的各项指标的
> | |
> Sun.Zhu
> |
> |
> 17626017841@163.com
> |
> 签名由网易邮箱大师定制
>
>
> 在2020年06月25日 00:51，徐骁<ff...@gmail.com> 写道：
> 两个方法确实可以, 但是要追踪起来很废时间, 对小白太不友好啊
>

Re: 如何快速定位拖慢速度的 operator

[徐骁 <ff...@gmail.com>]

好的 感谢两位我试试

Sun.Zhu <17...@163.com> 于2020年6月25日周四 下午11:19写道：

> 虽然chain在一起，但是可以通过metrics中看出来各个算子的各项指标的
> | |
> Sun.Zhu
> |
> |
> 17626017841@163.com
> |
> 签名由网易邮箱大师定制
>
>
> 在2020年06月25日 00:51，徐骁<ff...@gmail.com> 写道：
> 两个方法确实可以, 但是要追踪起来很废时间, 对小白太不友好啊
>