[ 
https://issues.apache.org/jira/browse/BEAM-11612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17549101#comment-17549101
 ] 

Danny McCormick commented on BEAM-11612:
----------------------------------------

This issue has been migrated to https://github.com/apache/beam/issues/20709

> [collection] environment do not respect flink-conf.yaml.
> --------------------------------------------------------
>
>                 Key: BEAM-11612
>                 URL: https://issues.apache.org/jira/browse/BEAM-11612
>             Project: Beam
>          Issue Type: Bug
>          Components: runner-flink
>            Reporter: Kyle Weaver
>            Priority: P3
>
> When the Flink master is set to -[auto] and- [collection], flink-conf.yaml 
> (from the FLINK_CONF_DIR environment variable, or the --flink-conf-dir option 
> of the job server) is disregarded.
> -This can result in some confusing behavior. For example, when [auto] creates 
> a local environment, an empty Configuration() object is used.-
> -[https://github.com/apache/beam/blob/dd71c9ac472b62ff3598d3db47b0f26985bbc82a/runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkExecutionEnvironments.java#L82-L85]-
>  



--
This message was sent by Atlassian Jira
(v8.20.7#820007)

Reply via email to