You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "limbo (Jira)" <ji...@apache.org> on 2020/09/26 09:30:00 UTC

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

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)