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

Aljoscha Krettek commented on FLINK-16560:
------------------------------------------

I think we don't need to fix it in 1.10.1, since the "buggy" behaviour is the 
same as before Flink 1.10, where we didn't read the Configuration at all in the 
environments. [~kkloudas] what do you think?

> StreamExecutionEnvironment configuration is empty when building program via 
> PackagedProgramUtils#createJobGraph
> ---------------------------------------------------------------------------------------------------------------
>
>                 Key: FLINK-16560
>                 URL: https://issues.apache.org/jira/browse/FLINK-16560
>             Project: Flink
>          Issue Type: Bug
>          Components: API / DataStream, Runtime / Configuration
>    Affects Versions: 1.10.0
>            Reporter: Zhu Zhu
>            Priority: Major
>             Fix For: 1.10.1, 1.11.0
>
>
> PackagedProgramUtils#createJobGraph(...) is used to generate JobGraph in k8s 
> job mode.
> The problem is that the configuration field of StreamExecutionEnvironment is 
> a newly created one when building the job program. This is because 
> StreamPlanEnvironment ctor will base on the no param version ctor of 
> StreamExecutionEnvironment.
> This may lead to an unexpected result when invoking 
> StreamExecutionEnvironment#configure(...) which relies on the configuration. 
> Many configurations in the flink conf file will not be respected, like 
> pipeline.time-characteristic, pipeline.operator-chaining, 
> execution.buffer-timeout, and state backend configs.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to