共用方式為


STREAMING_CHECKPOINT_METADATA_ERROR錯誤狀況

SQLSTATE: 42616

串流檢查點中繼資料發生錯誤。

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> 不支援跳過偏移量。 請將此來源從查詢中移除或倒帶,但不要跳過偏移量。