我们要使用的几个组件为Hadoop 2.6,HBase 1.0.0,MySQL 8,zookeeper 3.4.5,kafka 2.1.0,Flink 1.13,Canal 1.1.5。...为了方便,这里都使用伪集群和单机安装。.../startup.sh
此时当我们在数据库中插入一条数据的时候
insert into user_info (account,password,sex,age,phone,status,wechat_account...Flink技术整理 ,由于这里使用的是1.13.0,而之前使用的是1.7.2,有一些API已经不可用了。...String productTypeId;
private Long numbers = 0L;
private String groupField;
}
在DateUntil工具类中增加一个方法