You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "shijinkui (JIRA)" <ji...@apache.org> on 2016/09/23 09:38:20 UTC
[jira] [Created] (FLINK-4669) scala api createLocalEnvironment()
function add default Configuration parameter
shijinkui created FLINK-4669:
--------------------------------
Summary: 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)