Re: Flink on yarn ,并行度>1的情况下,怎么获取springboot的bean?

2022-04-22 文章 tison
@duwenwen 我比较好奇你的算子里做了什么,因为如果你就是要全局初始化唯一一次,那就用一个 parallelism=1 的算子去做就好了。 parallelism=n 你还要确保 once 的话应该得依赖外部系统来做到仅初始化一次。 Best, tison. Paul Lam 于2022年4月22日周五 18:16写道: > 听起来是在 Flink 里启动 springboot? 很有意思的架构,有一点点类似 statefun 了。可以说说这么做的背景吗? > > 另外请附带上 flink 的部署模式和版本信息,这样大家才好判断问题在哪里。 > > Best, >

Re: Flink on yarn ,并行度>1的情况下,怎么获取springboot的bean?

2022-04-22 文章 Paul Lam
听起来是在 Flink 里启动 springboot? 很有意思的架构,有一点点类似 statefun 了。可以说说这么做的背景吗? 另外请附带上 flink 的部署模式和版本信息,这样大家才好判断问题在哪里。 Best, Paul Lam > 2022年4月22日 16:30,duwenwen 写道: > > 您好: >首先很感谢您能在百忙之中看到我的邮件。我是一个写代码的新手,在使用flink框架过程中我遇到了一些问题,希望能得到您的解答。 >

Flink on yarn ,并行度>1的情况下,怎么获取springboot的bean?

2022-04-22 文章 duwenwen
您好: 首先很感谢您能在百忙之中看到我的邮件。我是一个写代码的新手,在使用flink框架过程中我遇到了一些问题,希望能得到您的解答。 由于需求要求,我需要将springboot和flink结合起来使用,我在open方法中获取springboot的上下文来获取bean。当设置parallelism为1时,可以发布到集群正常运行,但是当parallelism>1时,springboot的环境被多次初始化,运行就开始报错,,请问当parallelism>1