当我使用内联sql magi时，jupyter笔记本pyspark sparkmagic错误

Question

我已经成功地在jupyter笔记本中配置了PySpark内核，还安装了SparkMagic。 当我尝试使用以下命令时：

%%sql
SELECT DepDelay, ArrDelay FROM flightData

它开始工作，突然Spark停止抛出以下错误：

An error was encountered: Invalid status code '400' from http://localhost:8998/sessions/0/statements/4 with error payload: {"msg":"requirement failed: Session isn't active."}

您可以在这里找到完整的日志文件下载并查看。 https://drive.google.com/open?id=1lvYqQBUCiIFp4lz3aVnzMgBNd9fzqJiz

感谢你的帮助。 非常感谢

Answer 1

试试这样的单行线

%sql SELECTDepDelay, ArrDelay FROM flightData