下午公司 Doris 做一个 Schema Change 的操作,没想到改了两三个小时。 中间 Flink 写入的时候,挂了好几次,不知道什么原因,中间有些数丢了。 按照设想,这种情况应该起任务重新消费一下 Kafka ,但是计算资源和 Kafka 资源都不允许。
就让 AI 写了一个从 OSS 下载原始日志,然后模拟 FLINK 逻辑,离线恢复的程序,又让 AI 梳理了一个相关下游数据恢复的步骤。
吃饭回来,已经搞差不多了,就等我批准往线上数据库导入了。
如果自己搞估计要熬大夜了。
这是一个专为移动设备优化的页面(即为了让你能够在 Google 搜索结果里秒开这个页面),如果你希望参与 V2EX 社区的讨论,你可以继续到 V2EX 上打开本讨论主题的完整版本。
V2EX 是创意工作者们的社区,是一个分享自己正在做的有趣事物、交流想法,可以遇见新朋友甚至新机会的地方。
V2EX is a community of developers, designers and creative people.