Я пытаюсь создать структурированную потоковую передачу SQL от брокера MQTT: test = spark.readStream

Я использую spark 2.4 и запускаю pyspark следующим образом: ./bin/pyspark --packages org.apache

При получении кода структурированной потоковой передачи Spark появляется следующее исключение:...