不太清楚你定时读mysql是需要做什么，如果是维表join的话考虑temporal table join[1]，通过设置ttl时间和数量来更新缓存[2]
[1] https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/streaming/temporal_tables.html [2] https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/connectors/jdbc.html#how-to-create-a-jdbc-table zhao liang <zhao...@gmail.com> 于2020年8月27日周四 下午3:48写道： > > HI，我需要定时从MySQL中读取维表的数据，但是source的方法执行一遍就结束了，按open、run、close按序执行一遍，我在open方法中定义了ScheduledExecutorService来实现定时读取数据，但是job异常的时候这个线程无法被cancled，恢复策略会无线重启job，导致线程越来越多，想问问定时读维表有什么好的实现方法吗？ >
