环境:
hadoop 3.2.0
flink 1.11.4-bin-scala_2.11
hudi 0.8.0
本文基于上述组件版本使用flink插入数据到hudi数据湖中。.../hudi-flink-bundle_2.11/0.8.0/hudi-flink-bundle_2.11-0.8.0.jar
wget https://repo1.maven.org/maven2/commons-logging...',
'path' = 'hdfs://mycluster/tmp/t1',
'table.type' = 'MERGE_ON_READ'
);
插入数据到t1表
INSERT INTO...TIMESTAMP '1970-01-01 00:00:07','par4'),
('id8','Han',56,TIMESTAMP '1970-01-01 00:00:08','par4');
数据更新...insert into t1 values ('id1','Danny',27,TIMESTAMP '1970-01-01 00:00:01','par1');
数据查询
select * from