1. Zuhause
  2. Frage und Antwort
  3. Instantiate StreamExecutionEnvironment in Scala Shell

Instantiate StreamExecutionEnvironment in Scala Shell

2016-04-06 13 views
2

Ich starte die Scala-Shell. Es erstellt automatisch eine ExecutionEnvironment vom Typ org.apache.flink.api.scala.ExecutionEnvironmentInstantiate StreamExecutionEnvironment in Scala Shell

Allerdings möchte ich eine Streaming-Umgebung verwenden.

führt zu einer Ausnahme, da ExecutionEnvironement nur einmal instanziiert werden kann.

Quelle

2016-04-06 Stefan Papp

Antwort

3

Derzeit wird StreamExecutionEnvironment in der Flink Scala-Shell nicht unterstützt. Es gibt eine Pull-Anforderung (https://github.com/apache/flink/pull/1412), die dieses Problem anspricht. Vielleicht können Sie StreamExecutionEnvironment in der nächsten Version verwenden.

Quelle

2016-04-06 11:11:06

+0

Die Pull-Anforderung wurde zusammengeführt. Sie können die Scala Shell mit Streaming in der neuesten Apache Flink Snapshot Build ausprobieren. – mxm

Verwandte Themen

 Verwandte Themen