自定义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
[email protected] 发件人： [email protected] 发送时间： 2020-08-27 16:21 收件人： zhao liang; [email protected] 主题： 回复: Source 定时执行sql，只执行一次就close了source HI，我需要定时从MySQL中读取维表的数据，但是source的方法执行一遍就结束了，按open、run、close按序执行一遍，我在open方法中定义了ScheduledExecutorService来实现定时读取数据，但是job异常的时候这个线程无法被cancled，恢复策略会无线重启job，导致线程越来越多，想问问定时读维表有什么好的实现方法吗？
