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