[HUDI-1704] Use PRIMARY KEY syntax to define record keys for Flink Hudi table

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Done
• Fix Version/s: 0.8.0
• Component/s: flink
• Labels: pull-request-available
• Assignee: Danny Chen
• Reporter: Danny Chen
• Created: 18/Mar/21 02:38
• Updated: 18/Mar/21 12:22
• Resolved: 18/Mar/21 12:22

Description

The SQL PRIMARY KEY semantics is very same with Hoodie record key, using PRIMARY KEY is more straight-forward way instead of a table option: hoodie.datasource.write.recordkey.field.

After this change, both PRIMARY KEY and table option can define hoodie record key, while the PRIMARY KEY has higher priority if both are defined.

Issue Links

• links to: GitHub Pull Request #2694