You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Fangliang Liu (Jira)" <ji...@apache.org> on 2022/04/17 11:35:00 UTC

[jira] [Created] (FLINK-27275) Support null value not update in flink-connector-jdbc

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)