Lim Chee Hau created FLINK-7000: ----------------------------------- Summary: Add custom configuration for StreamExecutionEnvironment#createLocalEnvironment Key: FLINK-7000 URL: https://issues.apache.org/jira/browse/FLINK-7000 Project: Flink Issue Type: Improvement Reporter: Lim Chee Hau
I was doing some local testings in {{Scala}} environment, however I found that there is no straightforward way to add custom configuration to {{StreamExecutionEnvironment}} by using {{createLocalEnvironment}} method. This could be easily achieve in {{Java}} environment since {{StreamExecutionEnvironment}} in {{Java}} has - createLocalEnvironment() - createLocalEnvironment(Int) - createLocalEnvironment(Int, Configuration) Whereas Scala only has 2 out of 3 of these methods. Not sure if this is a missing implementation, if yes I could create a PR for this. -- This message was sent by Atlassian JIRA (v6.4.14#64029)