?????? how to simulate the scene "back pressure" in flink?Thanks~!

[??????]

 Thanks for your repies,
could you tell me where to set RestOption.POPT?in configuration 
what's the value should I set for RestOption.PORT?


Thanks.




------------------ ???????? ------------------
??????:                                                                         
                                               "Arvid Heise"                    
                                                                
<ar...@ververica.com&gt;;
????????:&nbsp;2020??10??9??(??????) ????3:00
??????:&nbsp;"??????"<appleyu...@foxmail.com&gt;;
????:&nbsp;"David&amp;nbsp,Anderson"<dander...@apache.org&gt;;"user"<user@flink.apache.org&gt;;
????:&nbsp;Re: how to simulate the scene "back pressure" in flink?Thanks~!



The easiest way to see backpressure is to add some sleep to your sink, check 
[1] for an example.
If you execute that unit test with a RestOption.PORT set in the configuration, 
you can even load the Web UI and watch the backpressure accumulate and finally 
go away at the end of the test.



[1] 
https://github.com/apache/flink/blob/61a997364b020b44bd26df76208e76106c6390b5/flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointITCase.java#L536


On Tue, Oct 6, 2020 at 4:13 PM ?????? <appleyu...@foxmail.com&gt; wrote:



I want to learn the concept "back pressure".
but I can not find the datastream generator example to generate a lot of data.


besides,
is there any example on how to simulate the scene "back pressure"&nbsp; in WEB 
UI?


Thanks for your help~&nbsp;



-- 

Arvid Heise | Senior Java Developer




Follow us @VervericaData

--

Join Flink Forward - The Apache Flink Conference

Stream Processing | Event Driven | Real Time

--

Ververica GmbH | Invalidenstrasse 115, 10115 Berlin, Germany

--
Ververica GmbH
Registered at Amtsgericht Charlottenburg: HRB 158244 B
Managing Directors: Timothy Alexander Steinert, Yip Park Tung Jason, Ji (Toni) 
Cheng&nbsp;&nbsp;&nbsp;