(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,所以我想问下针对此情况是否有解决方案。
下面是我代码的具体实现思路:
1.通过实现Springboot的CommandLineRunner的run方法来起到等同于main方