STREAMING_CHECKPOINT_REWIND_ERROR 오류 조건

SQLSTATE: 42000

검사점 위치=<checkpointLocation>를 사용하여 스트리밍 쿼리에 대한 되감기 작업을 수행하지 못했습니다.

싱크 오프셋이 누락된 싱크를 복원할 수 없음

restoreSink=true를 사용한 되감기는 sinkOffset <sinkOffset> 이 유효하지 않으므로 수행할 수 없습니다. 다른 배치로 되돌리거나 restoreSink=false로 설정합니다.

찾을_수_없음_SINK_REWIND_PROVIDERS

batchId=<batchId>에서 싱크 되감기 공급자를 찾지 못했습니다.

소스 되감기 제공자를 찾지 못함

batchId=<batchId>에서 원본 되감기 공급자를 찾지 못했습니다.

유효하지 않은 되감기 제공자

이름=<rewindProviderName>이(가) 있는 잘못된 원본/싱크 되감기 공급자를 batchId=<batchId>에서 발견했습니다. 원본/싱크 공급자 이름=<providerName>, <sourceOrSinkId>에 대한 것입니다.

싱크는 복원을 지원하지 않습니다

싱크 <sinkName> 는 시간 이동에 대해 'restoreSink=true'를 지원하지 않습니다. 되감기 구성에서 'restoreSink=false'를 설정합니다.

싱크는 되감기/재생을 지원하지 않습니다

싱크 <sinkName> 는 시간 여행을 지원하지 않습니다. 시간 여행을 사용하지 않도록 설정하거나 Databricks 지원에 문의하세요.

소스 ID를 오프셋에서 찾을 수 없음

batchId=<sourceId>의 원본 ID '<batchId>'가 검사점 위치<checkpointLocation>의 최신 오프셋 로그에서 찾을 수 없습니다.

사용 가능한 원본 ID: [<availableSourceIds>].

이 오류는 스트리밍 쿼리가 되감기 대상 일괄 처리 후에 새 원본을 추가하도록 수정된 경우에 발생할 수 있습니다.

현재 쿼리 구성의 모든 원본이 대상 되감기 일괄 처리에 있는지 확인합니다.

SOURCE_OFFSET_METADATA_MISMATCH

batchId=<batchId>의 원본 오프셋 메타데이터 불일치입니다. 예상 소스 수는 <expectedNumSources>이지만, 실제 개수는 <actualNumSources>입니다.

상태 복원 실패

상태 저장소를 소스 일괄 처리 <sourceBatchId>에서 대상 일괄 처리 <targetBatchId>로 복원하지 못했습니다.

상태 검사점 파일이 존재하고 원본 일괄 처리에서 손상되지 않았는지 확인하거나, 이전의 다른 일괄 처리 시점으로 되돌리기를 선택하십시오.

시간 여행이 활성화되어 있지 않음

검사점 위치에 <checkpointLocation>는 시간 여행을 사용할 수 없습니다. 되감기 전에 시간 여행을 사용하도록 설정하세요. 새 쿼리의 경우 spark.databricks.streaming.queryMgmt.rewindReplay.enabled를 true로 설정하여 시간 여행을 사용하도록 설정합니다.

UNSUPPORTED_OFFSET_LOG_VERSION (지원되지 않는 오프셋 로그 버전)

batchId=<version>에서 지원되지 않는 오프셋 로그 버전 <batchId> 입니다. 되감기하려면 오프셋 로그 버전 2가 필요합니다. 오프셋 로그 버전 2를 사용하도록 설정하여 검사점이 생성되었는지 확인합니다.

지원되지 않는 상태 저장소 제공자

상태 저장소 공급자 <providerClass>에 대해 상태 저장 되감기 기능은 지원되지 않습니다.

상태 리와인드 작업에는 RocksDB 상태 저장소만 지원됩니다.