刚刚使用flink，有几个疑问，求各位了解的大大们，帮帮忙flink如何初始化spring上下文flink如何使用定时任务@codecraft@阿里云云栖社区@范闲叩谢
2 回答
红颜莎娜
TA贡献1842条经验 获得超12个赞
对于问题1：1、基本的原理就是在执行之前先加载下spring的context，为了避免重复重建，可以使用单利模式2、对于source、sink及transformation，可以使用继承AbstractRichFunction的相关function，在open的时候初始化springcontext3、对于springcontext的销毁，注册一个shutdownhook来销毁对于问题2：看是要怎么使用定时任务，如果是仅仅需要类似普通的spring中的schedule，那问题1解决了就可以了，如果是要在source或sink里头进行定时，估计要自己根据需求实现，比如使用cron4j等
添加回答
举报
0/150
提交
取消