[ https://issues.apache.org/jira/browse/FLINK-16560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17072777#comment-17072777 ]
Kostas Kloudas commented on FLINK-16560: ---------------------------------------- I think that this is resolved by https://issues.apache.org/jira/browse/FLINK-16658 but for the 1.11. For 1.10.1 there should be a separate fix. > 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: Blocker > 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)