我启动scala shell。它自动从org.apache.flink.api.scala.executionenvironment类型创建executionenvironment
但是，我想使用流媒体环境。
val senv = StreamExecutionEnvironment.getExecutionEnvironment导致异常，因为ExecutionEnvironment只能示例化一次。
我启动scala shell。它自动从org.apache.flink.api.scala.executionenvironment类型创建executionenvironment
但是，我想使用流媒体环境。
val senv = StreamExecutionEnvironment.getExecutionEnvironment导致异常，因为ExecutionEnvironment只能示例化一次。
1条答案
按热度按时间fae0ux8s1#
目前，
StreamExecutionEnvironment在flink scala shell中不支持。有一个请求(https://github.com/apache/flink/pull/1412)解决这个问题。也许你可以用StreamExecutionEnvironment在下一版本中。