[hotfix][table-common] Fix TableSchemaUtils#getPhysicalSchema should …

…keep the original constraint name
shuttie · Jun 11, 2020 · 28cc602 · 28cc602
1 parent 600ace2
commit 28cc602
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...table/flink-table-common/src/main/java/org/apache/flink/table/utils/TableSchemaUtils.java b/...table/flink-table-common/src/main/java/org/apache/flink/table/utils/TableSchemaUtils.java
@@ -58,7 +58,9 @@ public static TableSchema getPhysicalSchema(TableSchema tableSchema) {
 				}
 			});
 		tableSchema.getPrimaryKey().ifPresent(
-			uniqueConstraint -> builder.primaryKey(uniqueConstraint.getColumns().toArray(new String[0]))
+			uniqueConstraint -> builder.primaryKey(
+				uniqueConstraint.getName(),
+				uniqueConstraint.getColumns().toArray(new String[0]))
 		);
 		return builder.build();
 	}