一：控制平面组件。控制平面组件会为集群做出全局决策，比如资源的调度。以及检测和响应集群事件，例如当不满足部署的replicas字段时，要启动新的pod）。1.kube-apiserver。该组件负责公开了KubernetesAPI，负责处理接受请求的工作。API服务器是Kubernetes控制平面的前端。2.kube-controller-manager。负责运行控制器进程。从逻辑上讲，每个控制器都是一个单独的进程，但是为了降低复杂性，它们都被编译到同一个可执行文件，并在同一个进程中运行。3.cloud-controller-manager。嵌入了特定于云平台的控制逻辑。云控制器管理器（Clo
环境说明[flink-1.13.1-bin-scala_2.11.tgz](https://archive.apache.org/dist/flink/flink-1.13.1/flink-1.13.1-bin-scala_2.11.tgz)[hadoop-2.7.3.tar.gz](https://archive.apache.org/dist/hadoop/common/hadoop-2.7.3/hadoop-2.7.3.tar.gz)[flink-cdc-connectors](https://github.com/ververica/flink-cdc-connectors)(gitc
gitbash常用命令个人笔记，关于gitbash的常用命令1.常用文件和目录操作cd/进入根目录cd~进入用户目录usercd..返回上级目录cd../..返回二级cd./xxx进入当前目录下的xx目录ls查看目录中的文件ls-a查看目录中的文件，包含隐藏文件ls-al查看目录下所有文件及基本信息rm-f.gitignore删除文件.gitignorermdirdir1删除目录dir1rm-rfdir1删除目录dir1并且删除其中的所有文件mkdirdir1创建目录dir1touchxx.xx新建文件xx.xx2.git配置gitconfig--globaluser.name"xxname"
前言Git是一个分布式版本控制系统，用于跟踪和管理项目的代码变化。它由LinusTorvalds在2005年创建，现在是开源社区中最流行的版本控制工具之一。国内码云地址：工作台-Gitee.com版本控制系统(VCS)：Git用于跟踪文件和目录的变化，以便多个开发者可以协同工作，并记录项目的历史。每次更改都被记录为一个"提交"，并且可以随时回退到以前的提交状态。分布式系统：与一些中心化的版本控制系统不同，Git是分布式的，每个开发者都有完整的代码仓库的拷贝。这意味着即使没有网络连接，您也可以进行版本控制操作，然后在稍后将更改同步。仓库(Repository)：Git仓库是包含项目文件和历史记录
Docker从零开始，及常用命令大全（附带代码讲解）docker是一种开源的应用容器引擎，可以让开发者打包他们的应用以及依赖包到一个轻量级、可移植的容器中，然后发布到任何流行的Linux机器上，也可以实现虚拟化。docker使用客户端-服务器架构，客户端与守护进程通过RESTAPI进行通信，守护进程负责构建、运行和分发docker容器。docker的优势在于它的灵活性、轻量级、可移植性、松耦合、可扩展性和安全性。docker可以解决传统虚拟机技术的一些问题，比如启动速度慢、占用资源多、难以迁移等。docker还有一个集中存放镜像文件的仓储服务，叫做dockerregistry，可以方便地分享和
在此对Flink读写Hive表操作进行逐步记录，需要指出的是，其中操作Hive分区表和非分区表的DDL有所不同，以下分别记录。基础环境Hive-3.1.3Flink-1.17.1基本操作与准备1、上传依赖jar包到flink/lib目录下cpflink-sql-connector-hive-3.1.3_2.12-1.17.1.jarcpmysql-connector-j-8.1.0.jar2、更换planner依赖（Hive集成的推荐设置）mv/usr/sft/flink-1.17.1/opt/flink-table-planner_2.12-1.17.1.jar/usr/sft/flink-
Flink的API分层 ApacheFlink的API分为四个层次，每个层次都提供不同的抽象和功能，以满足不同场景下的数据处理需求。下面是这四个层次的具体介绍：CEPAPI：FlinkAPI最底层的抽象为有状态实时流处理。其抽象实现是ProcessFunction，并且ProcessFunction被 框架集成到了DataStreamAPI中来为我们使用。它允许用户在应用程序中自由地处理来自单流或多流的事件（数据），并提供具有全局一致性和容错保障的状态。此外，用户可以在此层抽象中注册事件时间（eventtime）和处理时间（processingtime）回调方法，从而允许程序可以
1流程图2Flink来源表建模--来源-城市topicCREATETABLENJ_QL_JC_SSJC_SOURCE(recordstring)WITH( 'connector'='kafka', 'topic'='QL_JC_SSJC', 'properties.bootstrap.servers'='172.*.*.*:9092', 'properties.group.id'='QL_JC_SSJC_NJ_QL_JC_SSJC_SOURCE','scan.startup.mode'='group-offsets','properties.isolation.level'='read_com
1.主键字段为空问题错误信息org.apache.flink.table.api.TableException:Column'bus_no'isNOTNULL,however,anullvalueisbeingwrittenintoit.Youcansetjobconfiguration'table.exec.sink.not-null-enforcer'='DROP'tosuppressthisexceptionanddropsuchrecordssilently.问题原因 sink表定义了主键，flink-sql在使用jdbc插入时，定义的主键中的属性存在空值PRIMARYKEY(col
1、查看查看用户名：gitconfiguser.name查看密码：gitconfiguser.password查看邮箱：gitconfiguser.email查看配置信息（包含上面的信息）：$gitconfig--list2、新增、切换修改用户名gitconfig--globaluser.name“xxxx(新的用户名)”修改密码gitconfig--globaluser.password“xxxx(新的密码)”修改邮箱gitconfig--globaluser.email“xxxx@xxx.com(新的邮箱)”当我们需要在同一台电脑上使用不同的Git用户时，需要切换到不同的用户身份也是上面操
