刚刚使用flink，有几个疑问，求各位了解的大大们，帮帮忙flink如何初始化spring上下文flink如何使用定时任务@codecraft @阿里云云栖社区 @范闲 叩谢
1 回答
慕尼黑的夜晚无繁华
TA贡献1864条经验 获得超6个赞
对于问题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等
- 1 回答
- 0 关注
- 705 浏览
添加回答
举报
0/150
提交
取消