使用Flink SQL插入数据到Apache Hudi

1.启动Flink集群（搭建：略）

[bigdata@bigdata4 bin]$ ./start-cluster.sh

2.启动Flink SQL客户端

./sql-client.sh embedded -j hudi-flink-bundle_2.12-0.11.0-SNAPSHOT.jar shell

hudi的jar包获取有两种方式

• 直接编译，目录为’/编译目录/packaging/hudi-flink-bundle/target’
• 直接下载 https://repo.maven.apache.org/maven2/org/apache/hudi/hudi-flink-bundle_2.11/

3.创建表

Flink SQL> CREATE TABLE t1(
>   uuid VARCHAR