在独立kubernetes模式(会话集群)中部署flink之后,我无法使用flink GUI上传任何新作业。在单击+Add New按钮并选择jar file之后,进度条结束,不会发生任何事情。作业管理器日志中没有关于此问题的信息/错误。当我尝试上传任何文件时(例如,文本文件)我收到一个错误,日志中有一条信息:
"Exception occured in REST handler: Only Jar files are allowed."我还尝试上传了伪jar (一个名为.jar的空文件),它工作了--我可以上传这种类型的文件。
我有一个全新的、干净的Apache Flink集群在Kubernetes集群上运行。我已经使用了docker集线器镜像,并且尝试了两个不同的版本:
*1.13.2-scala_2.12-java8, and
1.13-scala_2.11-java8*但两个版本的结果是相同的。
我的部署是基于以下方法的:
我已经使用了本文附录#公共集群资源定义#中提供的yaml文件:
flink-configuration-configmap.yaml
jobmanager-service.yaml
taskmanager-session-deployment.yaml
jobmanager-session-deployment-non-ha.yaml我还使用入口控制器在jobmanager上发布了运行在8081上的GUI。
我有树pod (1个jobmanager,2个任务管理器),在flink日志中看不到任何错误。
有什么建议我遗漏了什么,或者什么时候发现任何错误?
发布于 2021-09-02 13:25:24
问题解决了。nginx上传限制导致的问题(默认为1024kb)。Flink GUI使用入口控制器和nginx在Kubernetes外部发布。当我们尝试上传大于1MB (1024kb)的作业文件时,nginx限制阻止我们这样做。大小低于此限制的作业(例如0kb大小的伪造jar )已成功上载
https://stackoverflow.com/questions/69015398
复制相似问题