Re: 请问如何模拟一个back pressure的场景,应该如何实现?谢谢

Sat, 03 Oct 2020 05:57:03 -0700 

hi, Jark 老师有个博文提到过这些，可以参考一下并模拟下[1][2]。

[1]
http://wuchong.me/blog/2016/04/26/flink-internals-how-to-handle-backpressure/
[2] https://www.ververica.com/blog/how-flink-handles-backpressure

大森林 <[email protected]> 于2020年10月3日周六 下午8:03写道：

> 您好!
> 请问处理的速度
> 和消费的速度
> 在代码上应该怎么体现呢?
> 谢谢您
>
>
> ------------------&nbsp;原始邮件&nbsp;------------------
> 发件人:
>                                                   "user-zh"
>                                                                     <
> [email protected]&gt;;
> 发送时间:&nbsp;2020年10月3日(星期六) 晚上6:36
> 收件人:&nbsp;"user-zh"<[email protected]&gt;;
>
> 主题:&nbsp;回复：请问如何模拟一个back pressure的场景,应该如何实现?谢谢
>
>
>
> 你可以在处理一条log的时候做的复杂些 使得处理的没有消费的快就造成背压了
> ------------------&amp;nbsp;原始邮件&amp;nbsp;------------------
> 发件人:&amp;nbsp;&amp;quot;大森林&amp;quot;<[email protected]&amp;gt;
> 发送时间:&amp;nbsp;2020年10月3日(星期六) 下午2:41
> 收件人:&amp;nbsp;&amp;quot;user-zh&amp;quot;<[email protected]
> &amp;gt;;
> 主题:&amp;nbsp;请问如何模拟一个back pressure的场景,应该如何实现?谢谢

回复