我们将flink与springboot结合使用，我注意到在本地windows环境中正确初始化的bean，当我在flink cluster（4个任务管理器，1个作业管理器）部署时，它抛出npe，表示bean未初始化。
在进一步阅读时，我发现有一个操作符运行在不同的jvm上，而不是实际加载spingboot并初始化所有bean的jvm。
我想了解用flink代码编写springboot的最佳方法是什么。一种方法是在processor类（实现comap的类）的open方法中手动初始化所有bean
如果你能分享一些代码的例子，这将是伟大的。