[
https://issues.apache.org/jira/browse/FLINK-20452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-20452.
---------------------------
Resolution: Not A Problem
> Mysql JDBC Sink UpsertStreamTableSink requires that Table has a full primary
> keys
> ---------------------------------------------------------------------------------
>
> Key: FLINK-20452
> URL: https://issues.apache.org/jira/browse/FLINK-20452
> Project: Flink
> Issue Type: Bug
> Environment: {code:java}
> CREATE TABLE table_name (
> report_date VARCHAR not null,
> group_id VARCHAR not null,
> shop_id VARCHAR not null,
> shop_name VARCHAR,
> food_category_name VARCHAR,
> food_name VARCHAR,
> unit VARCHAR,
> rt_food_unit_cnt BIGINT,
> rt_food_unit_real_amt double,
> rt_food_unit_bill_rate double,
> rt_food_unit_catagory_rate double,
> rt_food_unit_all_rate double,
> PRIMARY KEY (report_date, group_id, shop_id) NOT ENFORCED
> ) WITH (
> 'connector.type' = 'jdbc',
> 'connector.driver' = 'com.mysql.jdbc.Driver',
> 'connector.url' = 'jdbc:mysql://host:port/db?autoReconnect=true',
> 'connector.table' = 'table',
> 'connector.username' = 'xxx',
> 'connector.password' = 'xxx',
> 'connector.write.flush.max-rows' = '100'
> )
> {code}
> Reporter: HideOnBush
> Priority: Blocker
>
> I specified PRIMARY KEY (report_date, group_id, shop_id) NOT ENFORCED when I
> created the table in 1.11, but I still get an error when I execute insert
> into Mysql JDBC Sink: UpsertStreamTableSink requires that Table has a full
> primary keys if it is updated? Why？1.11 Doesn't it support DDL to specify
> Primary key?
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
