You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ja...@apache.org on 2020/06/11 09:04:11 UTC
[flink] 01/04: [hotfix][table-common] Fix
TableSchemaUtils#getPhysicalSchema should keep the original constraint name
This is an automated email from the ASF dual-hosted git repository.
jark pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 28cc602f86f916001cf9ea409a273019e4da5ef8
Author: Jark Wu <ja...@apache.org>
AuthorDate: Mon Jun 8 18:46:01 2020 +0800
[hotfix][table-common] Fix TableSchemaUtils#getPhysicalSchema should keep the original constraint name
---
.../src/main/java/org/apache/flink/table/utils/TableSchemaUtils.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/TableSchemaUtils.java b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/TableSchemaUtils.java
index 67ee125..9efc1f3 100644
--- a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/TableSchemaUtils.java
+++ b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/TableSchemaUtils.java
@@ -58,7 +58,9 @@ public class TableSchemaUtils {
}
});
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();
}