You can add conf.setInteger(RestOptions.PORT, RestOptions.PORT.defaultValue());
at any place before creating the environment [1]. Default value is 8081, so you can access web ui through http://localhost:8081, but you can really choose any other free port. [1] https://github.com/apache/flink/blob/61a997364b020b44bd26df76208e76106c6390b5/flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointITCase.java#L198 On Fri, Oct 9, 2020 at 9:24 AM 大森林 <appleyu...@foxmail.com> wrote: > 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>; > *发送时间:* 2020年10月9日(星期五) 下午3:00 > *收件人:* "大森林"<appleyu...@foxmail.com>; > *抄送:* "David ,Anderson"<dander...@apache.org>;"user"< > user@flink.apache.org>; > *主题:* 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> 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 > -- 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
