Skip to content

Commit d35de09

Browse files
committed
Merge remote-tracking branch 'origin/develop' into develop
2 parents 210747c + 59c968c commit d35de09

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)