Flink application on k8s 有没有和 session 模式通过-C 指定额外的 jar 的相同功能啊?

简介: Flink application on k8s 有没有和 session 模式通过-C 指定额外的 jar 的相同功能啊?

Flink在Kubernetes上的部署可以通过ConfigMap和Secret来提供额外的jar包和配置文件。具体步骤如下:

  1. 将所需的jar包打包成一个压缩文件,例如my-flink-job.jar.zip。
  2. 创建一个ConfigMap,将压缩文件添加到其中。可以使用以下命令创建ConfigMap:

    kubectl create configmap my-flink-config --from-file=my-flink-job.jar.zip
    
  3. 在Flink的部署文件中,引用ConfigMap中的jar包。例如,可以在Deployment的spec.template.spec.containers.volumeMounts中添加以下内容:

    - name: flink-config
      mountPath: /opt/flink/lib
    volumes:
    - name: flink-config
      configMap:
        name: my-flink-config
    
  4. 在Flink的启动命令中,使用--classpath参数指定ConfigMap中的jar包。例如:

    kubectl run my-flink --image=my-flink-image --restart=Never --command -- bin/bash -c "cd /opt/flink && bin/flink run -m yarn-cluster -c com.example.MyFlinkJob --classpath /opt/flink/lib/*.jar"
    

这样,就可以在Kubernetes上运行带有额外jar包的Flink应用程序了。

相关实践学习
基于Hologres+Flink搭建GitHub实时数据大屏
通过使用Flink、Hologres构建实时数仓,并通过Hologres对接BI分析工具(以DataV为例),实现海量数据实时分析.
实时计算 Flink 实战课程
如何使用实时计算 Flink 搞定数据处理难题?实时计算 Flink 极客训练营产品、技术专家齐上阵,从开源 Flink功能介绍到实时计算 Flink 优势详解,现场实操,5天即可上手! 欢迎开通实时计算 Flink 版: https://cn.aliyun.com/product/bigdata/sc Flink Forward Asia 介绍: Flink Forward 是由 Apache 官方授权,Apache Flink Community China 支持的会议,通过参会不仅可以了解到 Flink 社区的最新动态和发展计划,还可以了解到国内外一线大厂围绕 Flink 生态的生产实践经验,是 Flink 开发者和使用者不可错过的盛会。 去年经过品牌升级后的 Flink Forward Asia 吸引了超过2000人线下参与,一举成为国内最大的 Apache 顶级项目会议。结合2020年的特殊情况,Flink Forward Asia 2020 将在12月26日以线上峰会的形式与大家见面。
目录
相关文章
|
Kubernetes Java Docker
利用(K8S)配合Docker部署jar包
通过Docker打包并部署到Kubernetes(K8S)集群的过程。首先,通过SpringBoot生成jar包,接着在K8S环境中创建并编辑Dockerfile文件。随后构建Docker镜像,并将其推送到镜像仓库。最后,通过一系列kubectl命令(如get pods、get svc、logs等),展示了如何在K8S中管理应用,包括查看Pod状态、服务信息、Pod日志以及重启Pod等操作。
1177 3
|
Kubernetes 虚拟化 网络架构
在K8S中,flannel有几种模式?
在K8S中,flannel有几种模式?
|
存储 Kubernetes 调度
|
Kubernetes Cloud Native 流计算
Flink-12 Flink Java 3分钟上手 Kubernetes云原生下的Flink集群 Rancher Stateful Set yaml详细 扩容缩容部署 Docker容器编排
Flink-12 Flink Java 3分钟上手 Kubernetes云原生下的Flink集群 Rancher Stateful Set yaml详细 扩容缩容部署 Docker容器编排
566 3
|
存储 Kubernetes 前端开发
k8s部署DataEase1.16.0cluster模式
k8s部署DataEase1.16.0cluster模式
|
存储 Kubernetes 安全
在K8S中,你用的flannel是哪个工作模式及fannel的底层原理如何实现数据报文转发的?
在K8S中,你用的flannel是哪个工作模式及fannel的底层原理如何实现数据报文转发的?
|
Kubernetes 负载均衡 算法
k8s学习--kube-proxy的三种工作模式详细解释
k8s学习--kube-proxy的三种工作模式详细解释
1013 0
|
Kubernetes Linux 容器
K8S中,flannel有几种模式?
K8S中,flannel有几种模式?
|
Kubernetes 负载均衡 监控
在K8S中,kube-proxy的工作模式是什么?
在K8S中,kube-proxy的工作模式是什么?
|
存储 Kubernetes 容器
在k8S中,所支持的存储供应模式有哪些?
在k8S中,所支持的存储供应模式有哪些?

热门文章

最新文章

推荐镜像

更多