apache-spark - from pyspark.streaming import StreamingContext ImportError: No module named streaming

Question

from pyspark.streaming import StreamingContext ImportError: No module named streaming

当我尝试通过 pyspark 使用流式传输时，会出现此错误。我成功地能够通过 scala 使用流式传输。

导入 org.apache.spark.streaming._

不给出错误，我能够运行该程序。

我在http://hortonworks.com/hadoop-tutorial/using-apache-spark-hdp/上运行 spark

Answer 1

Spark Streaming 的 Python API 是最新的，它是在 1.2 版本中添加的（阅读更改日志）。检查您使用的是哪个版本？