请问下,flink sql 创建后,源库删除,目标不删除,这个操作有好的解决方法没呀?
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
别慌,这操作挺常见的。Flink 是流式的,源表一删,Job 直接挂,报错 Table not found,但目标库的数据确实还在,只是不更新了。
正确姿势:
先 Cancel Job:去 Flink UI 或 CLI 把任务停了,别让它在那儿报错消耗资源。
再动源表:确认没流量了,再去源库删表或改名备份。
最后处理 DDL:如果不用了,再把 Flink 里的表定义也删了,保持干净。
要是你只是想“保留历史数据,停止写入”,千万别直接删源表!先把源表重命名(比如加个 _bak),或者清空数据。这样万一要恢复,随时能接上。
总结:先停任务,再删元数据。顺序反了,Job 必崩。
官方详细解决方案:https://www.aliyun.com/product/flink