Fangliang Liu created FLINK-27275: ------------------------------------- Summary: Support null value not update in flink-connector-jdbc Key: FLINK-27275 URL: https://issues.apache.org/jira/browse/FLINK-27275 Project: Flink Issue Type: New Feature Components: Connectors / JDBC Affects Versions: 1.14.3 Reporter: Fangliang Liu
The follow DDL {code:java} CREATE TABLE IF NOT EXISTS `db`.`tablea` ( `user_id` bigint, `A` string, `B` string, `C` string, `flag` varchar(256), PRIMARY KEY (`user_id`) NOT ENFORCED )WITH ( 'connector' = 'jdbc', 'url' = 'jdbc:mysql://xx.xx.xx.xx:xxx/test', 'table-name' = 'user', 'username'='root', 'password'='root', 'sink.buffer-flush.interval'='1s', 'sink.buffer-flush.max-rows'='50', 'sink.parallelism'='2' ); {code} -- This message was sent by Atlassian Jira (v8.20.1#820001)