flink 如何初始化 spring

Question

刚刚使用flink，有几个疑问，求各位了解的大大们，帮帮忙
flink如何初始化spring上下文
flink如何使用定时任务
@codecraft@阿里云云栖社区@范闲叩谢

Answer 1

对于问题1：1、基本的原理就是在执行之前先加载下spring的context，为了避免重复重建，可以使用单利模式2、对于source、sink及transformation，可以使用继承AbstractRichFunction的相关function，在open的时候初始化springcontext3、对于springcontext的销毁，注册一个shutdownhook来销毁对于问题2：看是要怎么使用定时任务，如果是仅仅需要类似普通的spring中的schedule，那问题1解决了就可以了，如果是要在source或sink里头进行定时，估计要自己根据需求实现，比如使用cron4j等