%flink.ssqlDROPTABLE IF EXISTS ch;
CREATETABLEch (
id String,
name String,
age String,
create_date Date
) WITH (
'connector'='clickhouse',
'url'='jdbc:clickhouse://172.16.8.164:8123,172.16.8.165:8123,172.16.8.166:8123/dc2', -- 可配置集群地址,写入时随机选择连接写入,不会一直使用一个连接写入'table-name'='user_name',
'username'='default',
'password'='',
'format'='json'
);
%flink.ssql(type=update)
select*from ch;
%flink.ssql(type=update)
insert into ch
select'8'as id, '3'as name, '4'as age, cast('2020-01-03'asDATE) as create_date