写文章
- @2501_92227359
简介
该用户还未填写简介
擅长的技术栈
未填写擅长的技术栈
可提供的服务
暂无可提供的服务
上传jar包到WebUI报错org.apache.flink.runtime.rest.handler.RestHandlerException
报错如上图所示，该报错主要是因为flink集群的版本和ideamaven中的flink版本不同导致的。第三行改为image: flink:1.18.0，因为没有指定版本会默认安装最新版本。在pom.xml文件中看flink版本。然后再yml配置文件中。
本地测试Flink就能收到kafka发送的消息，但是打包成jar包在webui部署就接受不到 解决方法
在java代码中写的端口号对应的是docker内部网络端口，打包成jar包后部署在webui后也相当于在docker容器里面运行了，这时候接收不到kafka发送的消息是因为容器内部通信问题，flink集群通过上图端口访问不到kafka，需要在yml配置文件把flink集群和kafka集群用一个网络连起来。更改配置文件后就能通过本地java代码在kafka生成模拟数据，然后flink就能接受到kaf
Vm虚拟机中配置hadoop（保姆级教程）
我用的虚拟机版本为Ubuntu 20.04.6 LTS。
Vm虚拟机中配置hadoop（保姆级教程）
我用的虚拟机版本为Ubuntu 20.04.6 LTS。
到底了