串流檢查點中繼資料發生錯誤。
COMMIT_LOG_V3_MISSING_SINK_METADATA
如果使用 spark.sql.streaming.commitLog.formatVersion >= 3,則必須提供接收中繼資料資訊。 某些串流模式與此格式版本不相容(連續模式、非同步進度追蹤、非同步狀態檢查點);請修復配置並重試。
檢測到待處理控制批次
偵測到操作Type=<operationType> 的待處理控制批次,且 batchId=<batchId> 與 queryId=<queryId>。 重新嘗試控制操作並重新執行查詢。
DETECTED_RUNNING_QUERY
偵測到正在執行帶有 ID <queryId>的串流查詢。 在執行回溯前停止正在執行的查詢。
無效提交日誌元數據
發現批次<batchId>的格式版本<commitLogFormatVersion>的提交紀錄中繼資料無效。 請使用正確的設定重新執行查詢。
缺少提交進度
在啟用時間旅行的批次<batchId>時發生錯誤。 請停用時間旅行功能或聯絡 Databricks 支援服務。
NO_QUERY_ID_FOUND
在檢查點位置 <checkpointLocation>找不到串流查詢 ID。 確認檢查點位置是否有效。
如果需要翻译,可能需要将其转化为中文,例如:回滾提交缺少接收器元数据
嘗試倒帶至批次<batchId>於檢查點位置<checkpointLocation>,但它不是用 spark.sql.streaming.commitLog.formatVersion >= 3 建立的。 提交紀錄中沒有可用的目標端中繼資料。 請使用具有接收中繼資料的批次重試,或使用正確的設定重新執行查詢。
REWIND_OFFSET_MISSING_METADATA
嘗試重置到批次<batchId>的檢查點位置<checkpointLocation>,但偏移日誌中沒有任何元資料。 請用有元資料的批次重試。
SKIP_OFFSETS_INVALID_SOURCE_ID
在 skipOffsets 中的來源 ID <sourceId> 無效,因為在檢查點位置 <checkpointLocation> 的 batchId=<batchId> 中可用的來源 ID=<availableSourceIds> 中不存在。 請檢查查詢是否被修改以移除此來源並重新加入。
來源不支持跳過偏移量(SKIP_OFFSETS)
Source <sourceName> 不支援跳過偏移量。 請將此來源從查詢中移除或倒帶,但不要跳過偏移量。