官网给的示例命令如下 ./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邮件归档
目前native的方式只能支持local,也就是用户jar需要打到镜像里面,暂时不能支持hdfs或oss
是可以通过init container来下载,目前pod template[1]这个功能还没有支持,你可以跟进进度
[1]. https://issues.apache.org/jira/browse/FLINK-15656*来自志愿者整理的flink邮件归档
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。