Details
-
Improvement
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
-
None
Description
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.
Therefore the example in Local Execution could be making sense for Scala users as well:
The LocalEnvironment allows also to pass custom configuration values to Flink.
Attachments
Issue Links
- links to
