structured-streaming

10Ciepło

1Odpowiedz

Dlaczego korzystanie z pamięci podręcznej podczas przesyłania strumieniowego zestawów danych kończy się niepowodzeniem z "AnalysisException: Zapytania ze źródłami strumieniowymi muszą być wykonywane za pomocą metody writeStream.start()"?

SparkSession .builder .master("local[*]") .config("spark.sql.warehouse.dir", "C:/tmp/spark") .config("spark.sql.streaming.checkpointLocation", "C:/tmp/spark/spark-checkpoint")

scala apache-spark apache-spark-sql apache-spark-2.0 structured-streaming 2017-02-06

---