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

SQLSTATE: 42000

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

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

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

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

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

INVALID_REWIND_PROVIDER

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

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

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

SOURCE_ID_NOT_FOUND_IN_OFFSETS

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

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

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

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

SOURCE_OFFSET_METADATA_MISMATCH

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

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

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

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

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