liwei li created FLINK-23775:
--------------------------------
Summary: Provide a method to create StreamExecutionEnvironment
with Configuration in scala api
Key: FLINK-23775
URL: https://issues.apache.org/jira/browse/FLINK-23775
Project: Flink
Issue Type: Improvement
Reporter: liwei li
When create flink env, if there are same Configuration parameters to configure,
need to create java api first, then switch to scala, can we provide a method
setting org.apache.flink.configuration.Configuration in scala env api . like
this:
def getExecutionEnvironment(configuration: Configuration):
StreamExecutionEnvironment = {
new StreamExecutionEnvironment(new JavaEnv(configuration))
}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
