sivabalan narayanan created HUDI-2282:
-----------------------------------------
Summary: Upsert for an already existing record throws
DuplicateKeyException with primary key spark sql table
Key: HUDI-2282
URL: https://issues.apache.org/jira/browse/HUDI-2282
Project: Apache Hudi
Issue Type: Improvement
Reporter: sivabalan narayanan
[https://gist.github.com/nsivabalan/9837a90b1481c479a9c600bf16bafa57]
{code:java}
create table hudi_test4 (id int, name string, price double, ts long) using hudi
options(primaryKey = 'id', precombineField = 'ts') partitioned by (name)
location 'file:///tmp/hudi_testing/hudi_test4';
insert into hudi_test4 values(1, 100.0, 100000010, "abc");insert into
hudi_test4 values(2, 200.0, 200000010, "abc");insert into hudi_test4 values(3,
300.0, 300000010, "abc");
// this throws DuplicateKeyException ? Even though operation w/ hudi is
"upsert". insert into hudi_test4 values(1, 600.0, 600000010, "abc");
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
