下午公司 Doris 做一个 Schema Change 的操作，没想到改了两三个小时。 中间 Flink 写入的时候，挂了好几次，不知道什么原因，中间有些数丢了。 按照设想，这种情况应该起任务重新消费一下 Kafka ，但是计算资源和 Kafka 资源都不允许。 就让 AI 写了一个从 OSS 下载原始日志，然后模拟 FLINK 逻辑，离线恢复的程序，又让 AI 梳理了一个相关下游数据恢复的步骤。 吃饭回来，已经搞差不多了，就等我批准往线上数据库导入了。 如果自己搞估计要熬大夜了。 AI, 恢复, schema
