开发者社区 问答 正文

请问下,flink sql 创建后,源库删除,目标不删除,这个操作有好的解决方法没呀?

已解决

请问下,flink sql 创建后,源库删除,目标不删除,这个操作有好的解决方法没呀?

展开
收起
30577918 2026-10-29 09:39:47 25 分享 版权
1 条回答
写回答
取消 提交回答
  • 采纳回答

    别慌,这操作挺常见的。Flink 是流式的,源表一删,Job 直接挂,报错 Table not found,但目标库的数据确实还在,只是不更新了。

    正确姿势:
    先 Cancel Job:去 Flink UI 或 CLI 把任务停了,别让它在那儿报错消耗资源。
    再动源表:确认没流量了,再去源库删表或改名备份。
    最后处理 DDL:如果不用了,再把 Flink 里的表定义也删了,保持干净。

    要是你只是想“保留历史数据,停止写入”,千万别直接删源表!先把源表重命名(比如加个 _bak),或者清空数据。这样万一要恢复,随时能接上。

    总结:先停任务,再删元数据。顺序反了,Job 必崩。

    官方详细解决方案:https://www.aliyun.com/product/flink

    2026-10-29 10:10:31
    赞同 27 展开评论
问答分类:
问答地址: