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> 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" in WEB > UI? > > Thanks for your help~ > -- Arvid Heise | Senior Java Developer <https://www.ververica.com/> Follow us @VervericaData -- Join Flink Forward <https://flink-forward.org/> - 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
