以下操作会引入状态：(1)聚合：SUM, COUNT, AVG, MAX, MIN 等。(2)窗口：TUMBLE, HOP, SESSION, CUMULATE 等。(3)JOIN：时间窗口 Join、流对表 Join。(4)DISTINCT去重操作 和 GROUP BY 分组操作。(5)OVER 窗口：滑动窗口聚合。(6)TOP N：ROW_NUMBER(), RANK() 等。(7)自定义 U

这里有一个注意点，就是flink端的精准一次。

虽然HDFS本身不支持随机读写，但是HBase通过其自身的结构和实现方式，可以在HDFS之上实现高效的随机读写特性。（1）基于hadoop, 和 HDFS是一种强依赖关系, HBase的吞吐量不是特别高, 支持高效的随机读写特性（即：大型表提供快速记录查找(和更新)）为。2.Hive可以用来进行统计查询，HBase可以用来进行实时查询，数据也可以从Hive写到HBase，或者从HBase写回Hiv

有两种原因导致连接不上：1、mysql的驱动包要和Kettle的版本对应，否则是连接不上的。2、mysql的访问权限是否开启1.版本问题自己对照下载2.mysql打开远程连接--password：是mysql密码mysql-> grant all privileges on *.* to 'root'@'%' identified by '123456' with grant option;

验证 MySQL 配置： Flink CDC 依赖 MySQL 的 binlog 功能进行数据采集。log_bin = mysql-bin# 开启 binlog 功能，文件名为 mysql-bin。expire_logs_days = 30# binlog 日志保留天数，自动清理超过30天的日志。（2）将下载的 JAR 文件放到 Flink 集群的 lib/ 目录 中，重启flink集群。启动fl

可以给cursor指定中文回答、给代码加注释、连接数据库的一些信息（用自己的）等使用频繁的信息。把flink官网贴给cursor分析，选择docs分析。可以基于一个项目中java文件里面任何代码进行分析。提问：flink 20的新特性。（1）基于项目全局修改报错。（2）单独解决每一个报错。

数据更新是指对具有相同 key的数据记录中的value 列进行修改。主键（Unique）模型：主键模型是专门为数据更新设计的一种数据模型。主键模型支持使用UPDATE语句进行少量数据更新，也支持通过导入方式进行批量更新。导入方式包括 Stream Load、Broker Load、Routine Load 和 Insert Into 等，所有导入操作都遵循“UPSERT”语义，即如果记录不存在则插

有两种原因导致连接不上：1、mysql的驱动包要和Kettle的版本对应，否则是连接不上的。2、mysql的访问权限是否开启1.版本问题自己对照下载2.mysql打开远程连接--password：是mysql密码mysql-> grant all privileges on *.* to 'root'@'%' identified by '123456' with grant option;

今天登陆发现Xshell连不上 ，有点纳闷，查看虚拟机才发现 ip发生改变。怪了--查看网络配置[root@localhost ~]# vi /etc/sysconfig/network-scripts/ifcfg-ens33--代码奉上--不行就把注释去掉#网络类型：以太网，下边这个是默认的TYPE="Ethernet"#ip设置成静态的，dhcp改成staticBOOTPROTO="stati

Windows ping不通虚拟机的解决方案