1. CREATE TABLE sourceT (
    2.   uuid varchar(20),
    3.   name varchar(10),
    4.   age int,
    5.   ts timestamp(3),
    6.   `partition` varchar(20)
    7. ) WITH (
    8.   'connector' = 'datagen',
    9.   'rows-per-second' = '1'
    10. );
    12. create table t2(
    13.   uuid varchar(20),
    14.   name varchar(10),
    15.   age int,
    16.   ts timestamp(3),
    17.   `partition` varchar(20)
    18. )
    19. with (
    20.   'connector' = 'hudi',
    21.   'path' = '$HUDI_DEMO/t2', -- $HUDI_DEMO 替换成的绝对路径
    22.   'table.type' = 'MERGE_ON_READ',
    23.   'write.bucket_assign.tasks' = '2',
    24.   'write.tasks' = '2',
    25.   'hive_sync.enable' = 'true',
    26.   'hive_sync.mode' = 'hms',
    27.   'hive_sync.metastore.uris' = 'thrift://ip:9083' -- ip 替换成 HMS 的地址
    28. );
    30. insert into t2 select * from sourceT;

    参考
    hudi快速入门