Source 定时执行sql，只执行一次就close了source怎么解决？
HI，我需要定时从MySQL中读取维表的数据，但是source的方法执行一遍就结束了，按open、run、close按序执行一遍，我在open方法中定义了ScheduledExecutorService来实现定时读取数据，但是job异常的时候这个线程无法被cancled，恢复策略会无线重启job，导致线程越来越多，想问问定时读维表有什么好的实现方法吗？ *来自志愿者整理的flink邮件归档
展开
收起
1
条回答
写回答
写回答
-
自定义Source,在run方法中定时读取，可参照flink-example自定义Source例子：https://github.com/apache/flink/blob/master/flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/windowing/SessionWindowing.scala*来自志愿者整理的flink
2021-12-07 20:20:25赞同 展开评论 打赏
问答分类：
问答标签：
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
问答排行榜
最热
最新
推荐问答
相关电子书
更多
