无法对检查点位置为<checkpointLocation>的流式查询执行回卷操作。
未能找到接收器回放提供者
未能在 batchId=<batchId> 找到接收器回卷提供程序。
找不到源回放提供程序
未能在 batchId=<batchId> 找到源回退提供程序。
无效倒带提供者
在 batchId=<rewindProviderName> 中找到名称为 name=<batchId> 的源/接收器回退提供程序无效。 源/接收器提供程序名称=<providerName> for <sourceOrSinkId>.
接收器不支持倒带重放
汇聚点 <sinkName> 不支持时间旅行。 请禁用时光倒流或联系 Databricks 技术支持。
SOURCE_ID_NOT_FOUND_IN_OFFSETS
在检查点位置 <sourceId> 的最新偏移日志中找不到位于 batchId=<batchId> 的源 ID “<checkpointLocation>”。
可用的源 ID:[<availableSourceIds>]。
如果在回退目标批处理后修改流式查询来添加新源,可能会出现此错误。
确保当前查询配置中的所有源都存在于目标重置批处理中。
SOURCE_OFFSET_METADATA_MISMATCH (源偏移元数据不匹配)
batchId=<batchId> 处的源偏移元数据不匹配。 期望的来源数量=<expectedNumSources>;实际得到的数量=<actualNumSources>。
时光旅行未启用
检查点位置<checkpointLocation>未启用时间旅行。 请在执行回放之前启用时间旅行。 对于新的查询,可以通过将 spark.databricks.streaming.queryMgmt.rewindReplay.enabled 设置为 true 来启用时间旅行功能。
不支持的偏移量日志版本
batchId=<version> 不支持的偏移量日志版本<batchId>。 Rewind 需要偏移日志版本 2。 确保在启用了偏移日志版本 2 的情况下创建检查点。