Skip to content

Commit 4aaa7a4

Browse files
committed
remove primary key field space
1 parent 2b5dd49 commit 4aaa7a4

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

core/src/main/java/com/dtstack/flink/sql/table/AbsTableParser.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -111,7 +111,7 @@ public void parseFieldsInfo(String fieldsInfo, TableInfo tableInfo){
111111
}
112112

113113
public static void dealPrimaryKey(Matcher matcher, TableInfo tableInfo){
114-
String primaryFields = matcher.group(1);
114+
String primaryFields = matcher.group(1).trim();
115115
String[] splitArry = primaryFields.split(",");
116116
List<String> primaryKes = Lists.newArrayList(splitArry);
117117
tableInfo.setPrimaryKeys(primaryKes);

0 commit comments

Comments
 (0)