@duwenwen 我比较好奇你的算子里做了什么，因为如果你就是要全局初始化唯一一次，那就用一个 parallelism=1 的算子去做就好了。
parallelism=n 你还要确保 once 的话应该得依赖外部系统来做到仅初始化一次。 Best, tison. Paul Lam <paullin3...@gmail.com> 于2022年4月22日周五 18:16写道： > 听起来是在 Flink 里启动 springboot? 很有意思的架构，有一点点类似 statefun 了。可以说说这么做的背景吗？ > > 另外请附带上 flink 的部署模式和版本信息，这样大家才好判断问题在哪里。 > > Best, > Paul Lam > > > 2022年4月22日 16:30，duwenwen <dww1692813...@163.com> 写道： > > > > 您好： > > 首先很感谢您能在百忙之中看到我的邮件。我是一个写代码的新手，在使用flink框架过程中我遇到了一些问题，希望能得到您的解答。 > 由于需求要求，我需要将springboot和flink结合起来使用，我在open方法中获取springboot的上下文来获取bean。当设置parallelism为1时，可以发布到集群正常运行，但是当parallelism>1时，springboot的环境被多次初始化，运行就开始报错，，请问当parallelism>1 > 或者说当taskmanager>1时，应该怎么处理才能顺利获取到springboot的bean？针对上述问题希望能从您那里获得相应解决方案，十分感谢。 > >
