[FLINK-34901] Update clause must EXCLUDED unique index

• Type: Bug
• Status: Open
• Priority: Critical
• Resolution: Unresolved
• Affects Version/s: jdbc-3.1.2
• Component/s: Connectors / JDBC
• Labels: pull-request-available
• Assignee: Unassigned
• Reporter: ouyangwulin
• Created: 21/Mar/24 06:44
• Updated: 02/Aug/24 17:49

Description

When writing Postgres data using flinke-connector-jdbc, using upsert mode, As docs 'https://www.postgresql.org/docs/current/sql-insert.html', when we use ON CONFLICT, Update clause must EXCLUDED unique index.
Or it will throw exceptions.like " modification of distribution columns in OnConflictUpdate is not supported Call getNextException to see other errors in the batch."

Whether you can modify the code is as follows：
String updateClause =
        

Arrays.stream(fieldNames)
.filter(fieldName -> !Arrays.asList(uniqueKeyFields).contains(fieldName))
.map(f -> quoteIdentifier(f) + "=EXCLUDED." + quoteIdentifier(f))
.collect(Collectors.joining(", "));

Issue Links

• links to: GitHub Pull Request #108