在Scala Shell中实例化StreamExecutionEnvironment

Question

我启动scala shell。它从org.apache.frink.api.scala.ExecutionEnvironment 类型自动创建ExecutionEnvironment

不过，我想使用流媒体环境。

val senv = StreamExecutionEnvironment.getExecutionEnvironment

导致异常，因为ExecutionEnvironment只能实例化一次。

Answer 1

目前Flink Scala shell不支持StreamExecutionEnvironment。存在拉取请求(https://github.com/apache/flink/pull/1412)解决这个问题。也许您可以在下一个版本中使用StreamExecutionEnvironment。