@山间草夫 Storm确实没有问题。但是flink这种方式在本地可以运行,集群中通过flink run无法运行。
flink整合spring bootFlink框架:Flink整合springboot 首先说一下, 为什么flink 需要集成flink, spring boot给我们带来了更好的框架整合, 同时使用spri...
@山间草夫 Storm确实没有问题。但是flink这种方式在本地可以运行,集群中通过flink run无法运行。
flink整合spring bootFlink框架:Flink整合springboot 首先说一下, 为什么flink 需要集成flink, spring boot给我们带来了更好的框架整合, 同时使用spri...
这种实现方式,在集群中通过flink run 命令执行的时候会报ClassNotFoundException org.springframework.boot.env.EnvironmentPostProcessor错误。好像是flink类加载默认采用child-first,而java采用双亲委派。不知道您有没有遇到这种问题?
flink整合spring bootFlink框架:Flink整合springboot 首先说一下, 为什么flink 需要集成flink, spring boot给我们带来了更好的框架整合, 同时使用spri...