Получение этой ошибки при чтении из kinesis:- Не удалось прочитать до конечного порядкового номера диапазона: SequenceNumberRange

Я использую искру для чтения данных из потока Kinesis и после чтения данных в течение некоторого времени я получаю эту ошибку ОШИБКА Исполнитель: Исключение в задаче 74.0 на этапе 52.0 (TID 339) org.apache.spark.SparkException: Не удалось прочитать до конца порядковый номер диапазона: SequenceNumberRange(godel-logs,shardId-000000000007,49591040259365283625183097566179815847537156031957172338,49591040259365283625183097600068424422974441881954418802,4517)

Может кто-нибудь, пожалуйста, скажите, почему я получаю эту ошибку и как ее устранить

0 ответов

Другие вопросы по тегам