240 发简信
IP属地:山西
  • @山间草夫 Storm确实没有问题。但是flink这种方式在本地可以运行,集群中通过flink run无法运行。

    flink整合spring boot

    Flink框架:Flink整合springboot 首先说一下, 为什么flink 需要集成flink, spring boot给我们带来了更好的框架整合, 同时使用spri...

  • 这种实现方式,在集群中通过flink run 命令执行的时候会报ClassNotFoundException org.springframework.boot.env.EnvironmentPostProcessor错误。好像是flink类加载默认采用child-first,而java采用双亲委派。不知道您有没有遇到这种问题?

    flink整合spring boot

    Flink框架:Flink整合springboot 首先说一下, 为什么flink 需要集成flink, spring boot给我们带来了更好的框架整合, 同时使用spri...