Springboot整合Flink

各位Flink社区大佬，您好！
    因需要和java后端的开发一起合作开发项目，现需要将Flink和Springboot进行整合，大体流程是：通过Dubbo获取配置中心上有关数据库连接池，kafka连接等配置信息，然后接收kafka数据流，
flink处理后写入数据库中。其中入库是通过mybatis做的持久化，各种bean是通过springboot注入初始化的。  目前在本地运行是可以的，但无法通过flink run方式提交到集群运行，各种报错。
    想请问一下社区中有没有大佬做过这块的工作，希望能给予小弟一下指教。

[tison]

如果能提供【本地可以，无法通过 flink run 方法提交到集群】的细节会更有帮助，乍一听也不知道报了什么错，

Best,
tison.


[hidden email] <[hidden email]> 于2019年8月22日周四 上午11:30写道：

> 各位Flink社区大佬，您好！
>
> 因需要和java后端的开发一起合作开发项目，现需要将Flink和Springboot进行整合，大体流程是：通过Dubbo获取配置中心上有关数据库连接池，kafka连接等配置信息，然后接收kafka数据流，
> flink处理后写入数据库中。其中入库是通过mybatis做的持久化，各种bean是通过springboot注入初始化的。
> 目前在本地运行是可以的，但无法通过flink run方式提交到集群运行，各种报错。
>     想请问一下社区中有没有大佬做过这块的工作，希望能给予小弟一下指教。

你不错误贴出来，没人能给你解决的？



[hidden email]
 
发件人： [hidden email]
发送时间： 2019-08-22 11:30
收件人： user-zh
主题： Springboot整合Flink
各位Flink社区大佬，您好！
    因需要和java后端的开发一起合作开发项目，现需要将Flink和Springboot进行整合，大体流程是：通过Dubbo获取配置中心上有关数据库连接池，kafka连接等配置信息，然后接收kafka数据流，
flink处理后写入数据库中。其中入库是通过mybatis做的持久化，各种bean是通过springboot注入初始化的。  目前在本地运行是可以的，但无法通过flink run方式提交到集群运行，各种报错。
    想请问一下社区中有没有大佬做过这块的工作，希望能给予小弟一下指教。