flink-1.11 ddl kafka-to-hive????

Tue, 21 Jul 2020 04:10:00 -0700 

hive-1.2.1
chk 
??????????????chk????????????????chk??????kafka????????????????hive??????????????????????????????????
String hiveSql = "CREATE  TABLE  stream_tmp.fs_table (\n" +
        "  host STRING,\n" +
        "  url STRING," +
        "  public_date STRING" +
        ") partitioned by (public_date string) " +
        "stored as PARQUET " +
        "TBLPROPERTIES (\n" +
        "  'sink.partition-commit.delay'='0 s',\n" +
        "  'sink.partition-commit.trigger'='partition-time',\n" +
        "  'sink.partition-commit.policy.kind'='metastore,success-file'" +
        ")";
tableEnv.executeSql(hiveSql);


tableEnv.executeSql("INSERT INTO  stream_tmp.fs_table SELECT host, url, 
DATE_FORMAT(public_date, 'yyyy-MM-dd') FROM stream_tmp.source_table");

回复