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

SQLSTATE: 42000

Не удалось выполнить операцию отката для потокового запроса с контрольной точкой в расположении=<checkpointLocation>.

НЕВОЗМОЖНО_ВОССТАНОВИТЬ_СИНК_БЕЗ_УКАЗАНИЯ_СМЕЩЕНИЯ_СИНКА

Перемотка с использованием restoreSink=true не может быть выполнена, так как offset приемника <sinkOffset> недопустим. Перемотайте к другому пакету или установите restoreSink=false.

НЕ УДАЛОСЬ НАЙТИ ПОСТАВЩИКОВ SINK REWIND

Не удалось найти поставщиков перемотки приемника в batchId=<batchId>.

FAILED_TO_FIND_SOURCE_REWIND_PROVIDERS (Не удалось найти поставщиков источника перемотки)

Не удалось найти поставщиков служб перемотки источника при batchId=<batchId>.

INVALID_REWIND_PROVIDER

Обнаружен недопустимый поставщик перемотки источника или приемника с именем=<rewindProviderName> в batchId=<batchId>. Имя поставщика источника или приемника=<providerName> для <sourceOrSinkId>.

If the context allows for translation: СИСТЕМА НЕ ПОДДЕРЖИВАЕТ ВОССТАНОВЛЕНИЕ Otherwise, if it must remain as is due to technical constraints, then no improvements would be applied.

Приемник <sinkName> не поддерживает параметр 'restoreSink=true' для временного перемещения. Задайте значение restoreSink=false в конфигурации перемотки.

ЦЕЛЬ_НЕ_ПОДДЕРЖИВАЕТ_ПЕРЕМОТКУ_И_ВОСПРОИЗВЕДЕНИЕ

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

SOURCE_ID_NOT_FOUND_IN_OFFSETS

Идентификатор источника "<sourceId>" в batchId=<batchId> не найден в последнем журнале смещения в расположении контрольной точки <checkpointLocation>.

Доступные исходные идентификаторы: [<availableSourceIds>].

Эта ошибка может возникать, если запрос потоковой передачи был изменен, чтобы добавить новый источник после целевого пакета перемотки.

Убедитесь, что все источники в текущей конфигурации запроса существуют в целевом пакете перемотки.

SOURCE_OFFSET_METADATA_MISMATCH

Несоответствие метаданных смещения источника при batchId=<batchId>. Ожидаемое количество источников=<expectedNumSources>, но получено число=<actualNumSources>.

ВОССТАНОВЛЕНИЕ_СОСТОЯНИЯ_НЕУДАЧНО

Не удалось восстановить хранилище состояний из исходного пакета <sourceBatchId> в пакет <targetBatchId>.

Убедитесь, что файлы контрольных точек состояния существуют и не повреждены в исходном пакете или выберите другой пакет для перемотки.

ПУТЕШЕСТВИЕ_ВО_ВРЕМЕНИ_НЕ_ВКЛЮЧЕНО

Путешествие во времени не включено для расположения контрольной точки <checkpointLocation>. Включите перемещение по времени перед выполнением перемотки. Для новых запросов включите функцию перемотки времени, задав для параметра spark.databricks.streaming.queryMgmt.rewindReplay.enabled значение true.

НЕПОДДЕРЖИВАЕМАЯ ВЕРСИЯ ЖУРНАЛА СМЕЩЕНИЙ

Неподдерживаемая версия лога смещения <version> при batchId=<batchId>. Для перемотки требуется журнал смещения версии 2. Убедитесь, что контрольная точка была создана с включенной поддержкой offset log версии 2.

НЕПОДДЕРЖИВАЕМЫЙ_ПОСТАВЩИК_ХРАНИЛИЩА_СОСТОЯНИЙ

Перемотка с отслеживанием состояния не поддерживается для поставщика <providerClass>хранилища состояний.

Для операций перемотки состояния поддерживается только хранилище состояния RocksDB.