[jira] [Created] (FLINK-19423) primary key position cause JDBC SQL upsert sink ArrayIndexOutOfBoundsException

[Shang Yuanchun (Jira)]

limbo created FLINK-19423:
-----------------------------

             Summary: primary key position cause JDBC SQL upsert sink ArrayIndexOutOfBoundsException
                 Key: FLINK-19423
                 URL: https://issues.apache.org/jira/browse/FLINK-19423
             Project: Flink
          Issue Type: Bug
          Components: Connectors / JDBC
    Affects Versions: 1.11.1
            Reporter: limbo


We found  that the primary key position can cause  ArrayIndexOutOfBoundsException

the sink like that:
{code:java}
CREATE TABLE `test`(
  col1 STRING,
  col2 STRING,
  col3 STRING,
  PRIMARY KEY (col1, col3) NOT ENFORCED ) WITH (
  'connector' = 'jdbc',
  ...
){code}
when the DELETE (cdc message) come , it will raise ArrayIndexOutOfBoundsException



--
This message was sent by Atlassian Jira
(v8.3.4#803005)