开发者社区> 问答> 正文

flink on k8s application mode指定运行作业jar包路径问题

官网给的示例命令如下 ./bin/flink run-application -p 8 -t kubernetes-application \

-Dkubernetes.cluster-id=flink-k8s-application-cluster \

-Dtaskmanager.memory.process.size=4096m \

-Dkubernetes.taskmanager.cpu=2 \

-Dtaskmanager.numberOfTaskSlots=4 \

-Dkubernetes.container.image=flink:latest \

local:///opt/flink/examples/streaming/TopSpeedWindowing.jar

这最后一行参数指定了作业jar包路径,请问只支持local模式吗?那这样的话就只能将作业打包进镜像了吧?有没有可能访问外部文件系统,例如hdfs或oss地址? 如果当前暂时不支持的话,还有别的workaround办法吗?我听说有一个init container,具体要如何操作呢?*来自志愿者整理的flink邮件归档

展开
收起
毛毛虫雨 2021-12-08 11:21:06 1316 0
1 条回答
写回答
取消 提交回答
  • 目前native的方式只能支持local,也就是用户jar需要打到镜像里面,暂时不能支持hdfs或oss

    是可以通过init container来下载,目前pod template[1]这个功能还没有支持,你可以跟进进度

    [1]. https://issues.apache.org/jira/browse/FLINK-15656*来自志愿者整理的flink邮件归档

    2021-12-08 16:22:36
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载

相关镜像