HideOnBush created FLINK-20452:
----------------------------------
Summary: 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
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)
