flink 如何初始化 spring

Question

刚刚使用flink，有几个疑问，求各位了解的大大们，帮帮忙

1. flink如何初始化spring上下文
2. flink如何使用定时任务

@codecraft @阿里云云栖社区 @范闲 叩谢

Answer 1

http://www.54tianzhisheng.cn/...

这里也有不少挺好的Flink博客，值得推荐！

对应的代码仓库在：https://github.com/zhisheng17...

Answer 2

对于问题1：
1、基本的原理就是在执行之前先加载下spring的context，为了避免重复重建，可以使用单利模式
2、对于source、sink及transformation，可以使用继承AbstractRichFunction的相关function，在open的时候初始化spring context
3、对于spring context的销毁，注册一个shutdown hook来销毁

对于问题2：
看是要怎么使用定时任务，如果是仅仅需要类似普通的spring中的schedule，那问题1解决了就可以了，如果是要在source或sink里头进行定时，估计要自己根据需求实现，比如使用cron4j等