flink java的API和scala的API创建环境的区别

Question

问题遇到的现象和发生背景

在创建flink的流式执行环境时，使用java的api可以配置端口号，但在scala的api中。无法配置端口号等conf配置

问题相关代码，请勿粘贴截图

java

   public static StreamExecutionEnvironment getExecutionEnvironment(Configuration configuration) {
        return Utils.resolveFactory(threadLocalContextEnvironmentFactory, contextEnvironmentFactory)
                .map(factory -> factory.createExecutionEnvironment(configuration))
                .orElseGet(() -> StreamExecutionEnvironment.createLocalEnvironment(configuration));
    }

scala

def getExecutionEnvironment: StreamExecutionEnvironment = {
    new StreamExecutionEnvironment(JavaEnv.getExecutionEnvironment)
  }

运行结果及报错内容

我的解答思路和尝试过的方法

我想要达到的结果

Answer 1

scala的换成 createRemoteEnvironment，getExecutionEnvironment只是其中一种方法