Re: Flink Overwrite parameters in ExecutorUtils

[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 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 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 with the doc 
> https://nightlies.apache.org/flink/flink-docs-release-1.11/ops/config.html 
> . 
> I wonder if there is any special reason for this？
> 
> Best,
> Dan Zou
> 

Re: Flink Overwrite parameters in ExecutorUtils

[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 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 with the doc
> https://nightlies.apache.org/flink/flink-docs-release-1.11/ops/config.html.
> I wonder if there is any special reason for this？
>
> Best,
> Dan Zou
>
>

Flink Overwrite parameters in ExecutorUtils

[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 with the doc 
https://nightlies.apache.org/flink/flink-docs-release-1.11/ops/config.html. I 
wonder if there is any special reason for this？

Best,
Dan Zou