无法在独立的 kubernetes flink 部署(会话模式)上通过 gui 提交新作业
Can't submit new job via gui on standalone kubernetes flink deployment (session mode)
在独立 kubernetes 模式(会话集群)中部署 flink 后,我无法使用 flink GUI 上传任何新作业。单击 +Add New 按钮并选择 jar 文件后,进度条结束,没有任何反应。
作业管理器日志中没有关于此的 information/error。
当我尝试上传任何文件(例如文本文件)时出现错误,日志中有一条信息:
"Exception occured in REST handler: Only Jar files are allowed."
我也尝试上传假 jar(一个名为 .jar 的空文件)并且它有效 - 我可以上传这种文件。
我在 Kubernetes 集群上有一个全新的、干净的 Apache Flink 集群 运行。
我使用了 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
我还使用入口控制器在 8081 上的 jobmanager 上发布 GUI 运行。
我有树 pods(1 个作业管理器,2 个任务管理器)并且无法从 flink 日志中看到任何错误。
有什么我遗漏的建议,或者什么时候可以找到任何错误?
问题已解决。问题是由 nginx 上传限制(默认为 1024kb)引起的。 Flink GUI 使用入口控制器和 nginx 在 Kubernetes 外部发布。
当我们尝试上传大于 1MB (1024kb) 的作业文件时,nginx 限制阻止了它。大小低于此限制的作业(例如大小为 0 kb 的假 jar)已成功上传
在独立 kubernetes 模式(会话集群)中部署 flink 后,我无法使用 flink GUI 上传任何新作业。单击 +Add New 按钮并选择 jar 文件后,进度条结束,没有任何反应。 作业管理器日志中没有关于此的 information/error。 当我尝试上传任何文件(例如文本文件)时出现错误,日志中有一条信息:
"Exception occured in REST handler: Only Jar files are allowed."
我也尝试上传假 jar(一个名为 .jar 的空文件)并且它有效 - 我可以上传这种文件。
我在 Kubernetes 集群上有一个全新的、干净的 Apache Flink 集群 运行。 我使用了 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
我还使用入口控制器在 8081 上的 jobmanager 上发布 GUI 运行。
我有树 pods(1 个作业管理器,2 个任务管理器)并且无法从 flink 日志中看到任何错误。
有什么我遗漏的建议,或者什么时候可以找到任何错误?
问题已解决。问题是由 nginx 上传限制(默认为 1024kb)引起的。 Flink GUI 使用入口控制器和 nginx 在 Kubernetes 外部发布。 当我们尝试上传大于 1MB (1024kb) 的作业文件时,nginx 限制阻止了它。大小低于此限制的作业(例如大小为 0 kb 的假 jar)已成功上传