Flink参数配置设置不生效

classic Classic list List threaded Threaded
3 messages Options
Reply | Threaded
Open this post in threaded view
|

Flink参数配置设置不生效

魏烽
各位大佬好:

    在flink-conf.yaml中设置参数execution.attached: false

   但是yarn logs查看此参数设置并没有生效,

   2020-08-15 09:40:13,489 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: execution.attached, true

   而且根据官网说明此参数默认应该是false才对,已确认在代码中并没有对此参数进行设置,请问这是什么情况呀?
Reply | Threaded
Open this post in threaded view
|

Re: Flink参数配置设置不生效

Yang Wang
如果你是on Yarn部署的话,execution.attached这个参数会在FlinkYarnSessionCli里面根据flink run的
cli option进行覆盖,所以你配置在flink conf里面是没有生效的。如果加了-d的话就为设置为false,反之
就是true

Best,
Yang

魏烽 <[hidden email]> 于2020年8月15日周六 上午9:44写道:

> 各位大佬好:
>
>     在flink-conf.yaml中设置参数execution.attached: false
>
>    但是yarn logs查看此参数设置并没有生效,
>
>    2020-08-15 09:40:13,489 INFO
> org.apache.flink.configuration.GlobalConfiguration            - Loading
> configuration property: execution.attached, true
>
>    而且根据官网说明此参数默认应该是false才对,已确认在代码中并没有对此参数进行设置,请问这是什么情况呀?
>
Reply | Threaded
Open this post in threaded view
|

Re: Flink参数配置设置不生效

魏烽
In reply to this post by 魏烽
Hi  Yang Wang

感谢您的答复:

启动命令是

flink run -m yarn-cluster -ys 2 -p 4 -yjm 2G -ytm 2G -c com.nequal.bdh.cdp.IDTest etltest.jar  --qu default

Per-job-cluster模式

 原始邮件
发件人: Yang Wang<[hidden email]>
收件人: user-zh<[hidden email]>
发送时间: 2020年8月17日(周一) 11:26
主题: Re: Flink参数配置设置不生效


如果你是on Yarn部署的话,execution.attached这个参数会在FlinkYarnSessionCli里面根据flink run的
cli option进行覆盖,所以你配置在flink conf里面是没有生效的。如果加了-d的话就为设置为false,反之
就是true

Best,
Yang

魏烽 <[hidden email]<mailto:[hidden email]>> 于2020年8月15日周六 上午9:44写道:

> 各位大佬好:
>
>     在flink-conf.yaml中设置参数execution.attached: false
>
>    但是yarn logs查看此参数设置并没有生效,
>
>    2020-08-15 09:40:13,489 INFO
> org.apache.flink.configuration.GlobalConfiguration            - Loading
> configuration property: execution.attached, true
>
>    而且根据官网说明此参数默认应该是false才对,已确认在代码中并没有对此参数进行设置,请问这是什么情况呀?
>