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

[大森林]

您好!
我想模拟一个
flink的back pressure的场景,
如果方便的话,
可否麻烦您给一个example(java/scala均可)呢?


我是两个节点组建的集群(笔记本+台式机),
请问应该如何实现?
谢谢!

[leiyanrui]

你可以在处理一条log的时候做的复杂些 使得处理的没有消费的快就造成背压了 ------------------ 原始邮件 ------------------
发件人:&nbsp;&quot;大森林&quot;<[hidden email]&gt;
发送时间:&nbsp;2020年10月3日(星期六) 下午2:41
收件人:&nbsp;&quot;user-zh&quot;<[hidden email]&gt;;
主题:&nbsp;请问如何模拟一个back pressure的场景,应该如何实现?谢谢

[大森林]

您好!
请问处理的速度
和消费的速度
在代码上应该怎么体现呢?
谢谢您


------------------&nbsp;原始邮件&nbsp;------------------
发件人:                                                                                                                        "user-zh"                                                                                    <[hidden email]&gt;;
发送时间:&nbsp;2020年10月3日(星期六) 晚上6:36
收件人:&nbsp;"user-zh"<[hidden email]&gt;;

主题:&nbsp;回复：请问如何模拟一个back pressure的场景,应该如何实现?谢谢



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

[Shengkai Fang]

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

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

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