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)
