????????????????????Flink CDC??????????????Unable to convert to LocalDateTime
from unexpected value '2020-02-25T23:26:14Z' of type
java.lang.String??MySQL??timestamp????Flink????????????????????
??????
flink-1.11.3,
flink-sql-connector-mysql-cdc-1.0.0.jar
Flink CDC??????????
CREATE TABLE byx_user_auth(
id BIGINT,
user_id BIGINT,
role TINYINT,
name STRING,
id_card_type TINYINT,
id_card STRING,
bank_card STRING,
phone STRING,
auth_type TINYINT,
remark STRING,
create_date TIMESTAMP,
create_user STRING,
update_date TIMESTAMP,
update_user STRING,
del_flag TINYINT,
proc_time AS PROCTIME() -- ????????????????????????
) WITH ('connector' = 'mysql-cdc',--??????
'hostname' = 'XXX',--mysql????
'port' = '3310',--mysql????
'username' = 'XXX',--mysql??????
'password' = 'XXX',--mysql????
'database-name' = 'byx_user',--??????????
'table-name' = 'byx_user_auth'
);
MySQL??????????
CREATE TABLE `byx_user_auth` (
`id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '????',
`user_id` bigint(20) NOT NULL COMMENT '????????',
`role` tinyint(4) NOT NULL COMMENT
'??????1-????????2-????????3-??????????4-??????????5-????????7-??????????',
`name` varchar(64) NOT NULL COMMENT '????????',
`id_card_type` tinyint(4) NOT NULL COMMENT '??????????
1-????????2-??????????????????3-??????4-??????????????????5-????????????????',
`id_card` varchar(32) NOT NULL COMMENT '',
`bank_card` varchar(64) NOT NULL COMMENT '',
`phone` varchar(11) DEFAULT NULL COMMENT '',
`auth_type` tinyint(4) NOT NULL COMMENT '',
`remark` varchar(255) DEFAULT NULL COMMENT '????',
`create_date` timestamp NULL DEFAULT CURRENT_TIMESTAMP COMMENT
'????????',
`create_user` varchar(20) DEFAULT NULL COMMENT '??????',
`update_date` timestamp NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE
CURRENT_TIMESTAMP COMMENT '????????',
`update_user` varchar(20) DEFAULT NULL COMMENT '??????',
`del_flag` tinyint(4) DEFAULT '0' COMMENT '??????????0-?????? 1-????',
PRIMARY KEY (`id`),
UNIQUE KEY `uk_four_factors`
(`name`,`id_card_type`,`id_card`,`bank_card`,`phone`),
KEY `idx_id_role` (`user_id`,`role`)
)
