Вызвано: org.apache.spark.SparkException: задание прервано из-за сбоя этапа: задание 0 на этапе 0.0 не выполнено 1 раз, последний сбой: потерянное задание 0.0 на этапе 0.0 (TID 0, localhost, драйвер исполнителя): org.apache.spark.api.python.PythonException: обратная связь (последний вызов был последним):
Файл "D: \ spark_kafka_es_kibana \ spark-2.3.3-bin-hadoop2.7 \ python \ lib \ pyspark.zip \ pyspark \ worker.py", строка 238, в основном
Файл "D: \ spark_kafka_es_kibana \ spark-2.3.3-bin-hadoop2.7 \ python \ lib \ pyspark.zip \ pyspark \ serializers.py", строка 690, в read_int
length = stream.read (4)
Файл "C: \ Users \ Dhinesh.m \ AppData \ Local \ Programs \ Python \ Python36 \ lib \ socket.py", строка 586, в readinto
вернуть self._sock.recv_into (b)
socket.timeout: тайм-аут