kubeadmin部署k8s集群1.安装要求一台或多台机器，操作系统 CentOS7.x-86_x64硬件配置：2GB 或更多 RAM，2个 CPU 或更多 CPU，硬盘 30GB 或更多集群中所有机器之间网络互通可以访问外网，需要拉取镜像禁止 swap 分区2.系统初始化（所有节点执行）2.1 关闭防火墙：$ systemctl stop firewalld # 临时$ systemctl di

启动任务和更新任务public void start( DataprocessParam dataprocessParam, DataMap target, Pair<Boolean, String> ifWithSavePoint) {Kafka kafka = dataprocessParam.getKafka();TaskInfo taskInfo = dataprocessPa

Flink 版本 1.13.3，使用 native k8s 部署模式，原采用 HDFS 作为状态快照（Checkpoint、Savepoint）的存储地址，但是由于仅使用了其 HDFS 作为状态快照存储地址，且 Hadoop 框架较重，在 k8s 集群中占用大量资源，现考虑将其替换为更轻量级的分布式文件系统——NFS。

flink1.13于5月4日发布，版本迭代之快，更是体现了其势不可挡的发展速度。社区活跃度逐步攀升，当然少不了与云原生等技术的集成。 本文主要讲解flink的原生k8s application模式部署步骤，原生k8本质上是flink内部集成了k8s，能够做到Taskmanager的弹性伸缩。而之所以采用application模式部署，是因其规避了session模式的资源隔离问题、per-job模式