未能執行串流查詢的倒帶操作,檢查點位置=<checkpointLocation>。
無法還原因缺少匯流排偏移的 SINK
無法執行 restoreSink=true 的重置操作,因為 sinkOffset <sinkOffset> 無效。 倒帶到不同的批次或設定 restoreSink=false。
找不到接收器回放提供者
找不到 batchId=<batchId> 的 sink rewind 提供者。
FAILED_TO_FIND_SOURCE_REWIND_PROVIDERS
未能找到 batchId=<batchId>. 的原始碼倒帶服務提供者。
無效的回放提供者
在 batchId=<rewindProviderName> 找到無效的原始碼/匯重倒帶提供者,名稱=<batchId>。 Source/Sink 提供者名稱=<providerName> 對 <sourceOrSinkId>。
資料接收端不支援還原
Sink <sinkName> 不支援「restoreSink=true」來執行時間回溯。 在倒帶設定中設定 'restoreSink=false'。
接收端不支援回放與重播
《Sink <sinkName> 》不支援時間旅行。 請停用時間旅行功能或聯絡 Databricks 支援服務。
SOURCE_ID_NOT_FOUND_IN_OFFSETS(來源ID在偏移中找不到)
在檢查點位置<sourceId>的最新偏移記錄中找不到批次ID=<batchId>的Source ID '<checkpointLocation>'。
可用來源 ID:[<availableSourceIds>]。
如果串流查詢在倒帶目標批次後被修改以新增來源,可能會發生此錯誤。
確保目前查詢配置中的所有來源在目標回溯批次時都已存在。
SOURCE_OFFSET_METADATA_MISMATCH
來源偏移元資料與 batchId=<batchId> 不匹配。 預期來源數量=<expectedNumSources>,但獲得的數量=<actualNumSources>。
STATE_RESTORATION_FAILED(狀態恢復失敗)
從來源批次 <sourceBatchId> 到 <targetBatchId>批次無法還原狀態儲存。
確認狀態檢查點檔案是否存在且來源批次未損壞,或選擇其他批次回溯。
時間旅行未啟用
未為檢查點位置 <checkpointLocation> 啟用時間旅行。 請先啟用時間旅行,再進行倒帶。 對於新查詢,請將 spark.databricks.streaming.queryMgmt.rewindReplay.enabled 設定為 true 以啟用時間旅行。
不支援的偏移量日誌版本
不支援的偏移量日誌版本 <version> ,位於 batchId=<batchId>。 倒帶需要第2版的偏移日誌。 確保檢查點是啟用偏移日誌版本 2 的。
不支援的狀態儲存提供者
狀態式倒帶不支援狀態儲存服務 <providerClass>提供者。
只有 RocksDB 狀態儲存庫支援有狀態倒帶操作。