Skip to content

Commit 78ec264

Browse files
committed
[fix-33057][core]定义表时primary key前未加','需要异常提示,修改出错
1 parent 3add900 commit 78ec264

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/AbstractTableParser.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -142,7 +142,7 @@ private Tuple2<String, String> extractType(String fieldRow, String tableName) {
142142
}
143143

144144
public void dealPrimaryKey(Matcher matcher, AbstractTableInfo tableInfo) {
145-
String primaryFields = matcher.group(1).trim();
145+
String primaryFields = matcher.group(2).trim();
146146
String[] splitArray = primaryFields.split(",");
147147
List<String> primaryKeys = Lists.newArrayList(splitArray);
148148
tableInfo.setPrimaryKeys(primaryKeys);

0 commit comments

Comments
 (0)