условие ошибки STREAMING_CHECKPOINT_METADATA_ERROR

SQLSTATE: 42616

Ошибка в метаданных контрольной точки потоковой передачи.

COMMIT_LOG_V3_MISSING_SINK_METADATA

Если используется spark.sql.streaming.commitLog.formatVersion >= 3, необходимо предоставить сведения о метаданных приемника. Некоторые режимы потоковой передачи несовместимы с этой версией формата (непрерывный режим, асинхронное отслеживание хода выполнения, асинхронная контрольная точка состояния); Исправьте конфигурации и повторите попытку.

ОБНАРУЖЕН ПАКЕТ УПРАВЛЕНИЯ В ОЖИДАНИИ

Обнаружен ожидающий пакет управления для operationType=<operationType> с batchId=<batchId> и queryId=<queryId>. Повторите операцию управления и повторно выполните запрос.

ОБНАРУЖЕН_ИСПОЛЬЗУЕМЫЙ_ЗАПРОС

Обнаружен запуск потокового запроса с идентификатором <queryId>. Остановите выполняющийся запрос перед выполнением перемотки.

НЕВЕРНЫЕ_ДАННЫЕ_ЖУРНАЛА_КОММИТОВ

Обнаружены недопустимые метаданные журнала фиксации для партии <batchId> с версией формата <commitLogFormatVersion>. Повторите запрос с правильной конфигурацией.

MISSING_COMMIT_PROGRESS

Произошла ошибка при включённом перемещении по времени для пакета <batchId>. Отключите поездки по времени или обратитесь в службу поддержки Databricks.

NO_QUERY_ID_FOUND

Идентификатор потокового запроса не найден в расположении <checkpointLocation>контрольной точки. Проверьте, является ли расположение контрольной точки допустимым.

REWIND_COMMIT_MISSING_SINK_METADATA

Попытка перемотки на пакет <batchId> в контрольной точке <checkpointLocation>, но оно не было создано с помощью spark.sql.streaming.commitLog.formatVersion >= 3. В журнале фиксации отсутствуют метаданные приемника. Повторите попытку с пакетом с доступными метаданными приемника или повторно выполните запрос с правильной конфигурацией.

REWIND_OFFSET_MISSING_METADATA (отсутствует метаданные для перемотки смещения)

Попытка возврата к пакету <batchId> в контрольной точке по расположению <checkpointLocation>, но в журнале смещения отсутствуют метаданные. Повторите попытку с пакетом с доступными метаданными.

SKIP_OFFSETS_INVALID_SOURCE_ID

Недопустимый исходный идентификатор <sourceId> в параметре skipOffsets для batchId=<batchId> не существует среди доступных исходных идентификаторов=<availableSourceIds> для местоположения контрольной точки <checkpointLocation>. Проверьте, был ли изменен запрос, чтобы удалить этот источник и повторно добавить его.

SOURCE_НЕ_ПОДДЕРЖИВАЕТ_ПРОПУСК_СМЕЩЕНИЙ

Источник <sourceName> не поддерживает возможность пропуска смещений. Пожалуйста, удалите этот источник из запроса или выполните перемотку, не пропуская смещения.