我启动了 scala shell。它会自动从 org.apache.flink.api.scala.ExecutionEnvironment 类型创建一个 ExecutionEnvironment
但是,我想使用流媒体环境。
val senv = StreamExecutionEnvironment.getExecutionEnvironment
导致异常,因为 ExecutionEnvironement 只能实例化一次。
我启动了 scala shell。它会自动从 org.apache.flink.api.scala.ExecutionEnvironment 类型创建一个 ExecutionEnvironment
但是,我想使用流媒体环境。
val senv = StreamExecutionEnvironment.getExecutionEnvironment
导致异常,因为 ExecutionEnvironement 只能实例化一次。
目前,StreamExecutionEnvironment
在 Flink Scala shell 中不支持。有一个拉取请求(https://github.com/apache/flink/pull/1412)解决了这个问题。也许你可以StreamExecutionEnvironment
在下一个版本中使用。