Я успешно настроил ядро PySpark в ноутбуке jupyter, я также установил SparkMagic. Когда я пытаюсь использовать приведенную ниже команду:
%%sql SELECT DepDelay, ArrDelay FROM flightData
, она начинает работать, и внезапно Spark прекращает выдавать следующую ошибку:
Обнаружена ошибка: неверный код состояния '400'от http://localhost:8998/sessions/0/statements/4 с ошибкой: {"msg": "требование не выполнено: сеанс не активен."}
вы можете найти полный файл журнала здесь, чтобы загрузить и взятьсмотрю. https://drive.google.com/open?id=1lvYqQBUCiIFp4lz3aVnzMgBNd9fzqJiz
Ценю вашу помощь. Большое спасибо заранее
Попробуйте в одной строке вот так
%sql SELECTDepDelay, ArrDelay FROM flightData