Re: Flink Overwrite parameters in ExecutorUtils

2022-02-18 Thread Zou Dan
Hi Austin, Thinks for your reply. For example, we want to test if we could improve the throughput by changing the value of `execution.buffer-timeout`. Best, Dan Zou > 2022年2月19日 00:33,Austin Cawley-Edwards 写道: > > Hi Dan, > > I'm not exactly sure why, but could you help me understand the use

Re: Flink Overwrite parameters in ExecutorUtils

2022-02-18 Thread Austin Cawley-Edwards
Hi Dan, I'm not exactly sure why, but could you help me understand the use case for changing these parameters in Flink SQL? Thanks, Austin On Fri, Feb 18, 2022 at 8:01 AM Zou Dan wrote: > Hi, > I am using Flink Batch SQL in version 1.11. I find that Flink will > overwrite some configurations i

Flink Overwrite parameters in ExecutorUtils

2022-02-18 Thread Zou Dan
Hi, I am using Flink Batch SQL in version 1.11. I find that Flink will overwrite some configurations in ExecutorUtils, which means this parameters bacome un-configurable, such as `pipeline.object-reuse` and `execution.buffer-timeout`, and the default value for this parameters will be not align