[ https://issues.apache.org/jira/browse/FLINK-4669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15764642#comment-15764642 ]
ASF GitHub Bot commented on FLINK-4669: --------------------------------------- Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2541 > scala api createLocalEnvironment() function add default Configuration > parameter > ------------------------------------------------------------------------------- > > Key: FLINK-4669 > URL: https://issues.apache.org/jira/browse/FLINK-4669 > Project: Flink > Issue Type: Improvement > Components: Streaming > Reporter: shijinkui > > scala program can't direct use createLocalEnvironment with custom Configure > object. > such as I want to start web server in local mode, I will do such as: > ``` > // set up execution environment > val conf = new Configuration > conf.setBoolean(ConfigConstants.LOCAL_START_WEBSERVER, true) > conf.setInteger(ConfigConstants.JOB_MANAGER_WEB_PORT_KEY, > ConfigConstants.DEFAULT_JOB_MANAGER_WEB_FRONTEND_PORT) > val env = new org.apache.flink.streaming.api.scala.StreamExecutionEnvironment( > > org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.createLocalEnvironment(2, > conf) > ) > ``` > so we need createLocalEnvironment function have a config parameter -- This message was sent by Atlassian JIRA (v6.3.4#6332)