无法在独立 Kubernetes flink 部署(会话模式)上通过 GUI 提交新作业



在独立kubernetes模式(会话集群)下部署flink后,我无法使用flink GUI上传任何新作业。单击+Add New按钮并选择jar file后,进度带结束,没有任何事情发生。作业管理器日志中没有关于此的信息/错误。当我尝试上传任何文件(例如。文本文件)我得到一个错误,并且在日志中有一个信息:

"Exception occured in REST handler: Only Jar files are allowed."

我也试过上传假的jar(一个名为.jar的空文件),它可以工作-我可以上传这种文件。

我有一个全新的,干净的Apache Flink集群运行在Kubernetes集群。我已经使用了docker hub映像,我尝试了两个不同的版本:

*1.13.2-scala_2.12-java8, and
1.13-scala_2.11-java8*

但是两个版本的结果是一样的。

我的部署基于如下方式:

1.13 https://ci.apache.org/projects/flink/flink - docs -释放- -/- docs/deployment/resource providers/standalone/kubernetes/

,我使用了附录#中提供的yaml文件常见集群资源定义#到本文:

flink-configuration-configmap.yaml
jobmanager-service.yaml
taskmanager-session-deployment.yaml
jobmanager-session-deployment-non-ha.yaml

我还使用了ingress controller来发布运行在8081上的GUI。

我有3个pod(1个作业管理器,2个任务管理器),从flink日志中看不到任何错误。

有什么建议,我错过了什么,或者什么时候发现任何错误?

问题解决。问题是由nginx上传限制(默认是1024kb)引起的。Flink GUI是使用入口控制器和nginx在Kubernetes外部发布的。当我们尝试上传大于1MB (1024kb)的作业文件时,nginx限制阻止了它。大小低于此限制的作业(例如大小为0 kb的假jar)上传成功

最新更新