Я пытаюсь отправить структурированные потоковые данные pyspark вasticsearch и получаю приведенную ниже ошибку.Как решить эту проблему?