无法恢复未完成的控制批处理 <batchId> 。
重新分区
重新分区批处理具有 <unfinishedNumPartition> 状态分区，但当前查询正在请求 <requestedNumPartition>。
将 spark.sql.streaming.stateStore.partitions 设置为 <unfinishedNumPartition>并重新运行查询。 重新分区成功完成后，可以将其更改为 <requestedNumPartition>
设置检查点属性
会话 conf <confKey> 与查询 <confValue> 的挂起批处理所需的值 <queryId> 不匹配。