Skip to content

Commit 59c968c

Browse files
committed
fix: Fixed an issue where paimon could not obtain the primary key correctly when creating a table
1 parent dc5a9ee commit 59c968c

File tree

1 file changed

+1
-1
lines changed
  • connectors/paimon-connector/src/main/java/io/tapdata/connector/paimon/service

1 file changed

+1
-1
lines changed

connectors/paimon-connector/src/main/java/io/tapdata/connector/paimon/service/PaimonService.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -460,7 +460,7 @@ public boolean createTable(TapTable tapTable, Log log) throws Exception {
460460
}
461461

462462
// Set primary keys
463-
Collection<String> primaryKeys = tapTable.primaryKeys();
463+
Collection<String> primaryKeys = tapTable.primaryKeys(true);
464464
if (primaryKeys != null && !primaryKeys.isEmpty()) {
465465
schemaBuilder.primaryKey(new ArrayList<>(primaryKeys));
466466
}

0 commit comments

Comments
 (0)