Dear all??

 ????
> CREATE TABLE sink (
>   id INT,
>   prod_nm STRING,
>  dtm timestamp,
>  primary key(id)  NOT ENFORCED --  '??????????????'
> ) 
> WITH (
>     'connector' = 'jdbc',
>     'url' = 
'jdbc:mysql://10.0.0.0:3306/rs_report?useUnicode=true&characterEncoding=UTF-8',
>     'table-name' = 'sink',
>     'driver' = 'com.mysql.jdbc.Driver',
>     'username' = 'dps',
>     'password' = 'dps'
> );

insert into sink
 select id,prod_nm,current_timestamp from product;



????????mysql ??dtm???????????? 
??????????????????????8??????????????????????????21????
 
insert into sink
 select id,prod_nm,localtimestamp from product;



????????mysql ??dtm???????????????? ??????????????????????????????????????8????.

回复