flink 如何初始化 spring

Question

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

1. flink如何初始化spring上下文

2. flink如何使用定时任务

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

Answer 1

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