условие ошибки 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.

ОТСУТСТВУЕТ_ФАЙЛ_МЕТАДАННЫХ

Местоположение точки проверки <checkpointLocation> находится в несогласованном состоянии: файл метаданных отсутствует, но журналы смещений и/или фиксаций содержат данные. Восстановите файл метаданных или создайте новый каталог контрольных точек.

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> не поддерживает возможность пропуска смещений. Пожалуйста, удалите этот источник из запроса или выполните перемотку, не пропуская смещения.

ОТСУТСТВУЕТ_МЕТАДАННЫЕ_СОСТОЯНИЯ_ДЛЯ_ВОЗВРАТА_НАЗАД

Не удалось считывать метаданные состояния для оператора <operatorId> в пакете <batchId> во время операции перемотки. Расположение контрольной точки: <checkpointLocation>. Файл метаданных может не существовать для этого пакета. Убедитесь, что целевой пакет имеет валидные метаданные состояния перед возвратом к предыдущему состоянию.