ScalaシェルでStreamExecutionEnvironmentをインスタンス化します

Question

スカラシェルを起動します。これは自動的にorg.apache.flink.api.scala.ExecutionEnvironmentタイプのExecutionEnvironmentを作成します

しかし、私はストリーミング環境を使いたいと思います。

val senv = StreamExecutionEnvironment.getExecutionEnvironment 

は、ExecutionEnvironmentを一度しかインスタンス化できないため、例外が発生します。

Answer 1

現在、StreamExecutionEnvironmentはFlink Scalaシェルではサポートされていません。この問題に対処するプルリクエスト（https://github.com/apache/flink/pull/1412）があります。おそらく、次のリリースでStreamExecutionEnvironmentを使用することができます。