【发布时间】:2020-09-22 13:41:21
【问题描述】:
我是 flink 新手,正在尝试将我的 flink 程序提交到我的 flink 集群。
我有一个在远程 kubernetes 上运行的 flink 集群和一个在 Azure 上的 blob 存储。
当我在本地机器上有 jar 文件时,我知道如何提交 flink 作业,但不知道如何使用远程 jar 文件提交作业(jar 可以通过 https 访问)
检查了文件,似乎没有提供像我们在spark中所做的那样
提前致谢
【问题讨论】:
-
我想你可以使用一个 init 容器将 job jar 下载到共享卷中,然后将本地 jar 提交给 Flink。请参阅此示例以获取 GCS github.com/GoogleCloudPlatform/flink-on-k8s-operator/blob/…
-
@Dagang 是的,我想我必须创建一个restful服务器或复制任务来共享卷。
标签: apache-flink