(SelectStockJob.getClass,
profiles)
}
repository = SpringContextHolder.getBean(classOf[xxxRepository])
}
wch...@163.com
发件人： 676360...@qq.com.INVALID
发送时间： 2022-04-18 14:28
收件人： user-zh@flink.apache.org
主题： flink发布集群端运行，如何在sink或source中使用springboot的bean
您好：
首先很感谢您能在百忙之中看到我的邮件。在使用flink框架过程中我遇到了一些
您好：
首先很感谢您能在百忙之中看到我的邮件。在使用flink框架过程中我遇到了一些问题，希望能得到您的解答。
我通过网上已有的资料进行学习，在本地环境将springboot框架与flink进行结合，并可以成功运行。但是当我将项目通过maven打包成jar包后，发布到flink集群端时，在自定义sink和source类中无法获取到springboot的ApplicationContext，所以我想问下针对此情况是否有解决方案。
下面是我代码的具体实现思路：
