2

我启动了 scala shell。它会自动从 org.apache.flink.api.scala.ExecutionEnvironment 类型创建一个 ExecutionEnvironment

但是,我想使用流媒体环境。

val senv = StreamExecutionEnvironment.getExecutionEnvironment

导致异常,因为 ExecutionEnvironement 只能实例化一次。

4

1 回答 1

3

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

于 2016-04-06T11:11:06.947 回答