Skip to content

Commit 91a6768

Browse files
committed
修复重复名称的新名称生成规则
1 parent 73b5086 commit 91a6768

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

core/src/main/java/com/dtstack/flink/sql/util/ParseUtils.java

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -146,10 +146,8 @@ public static void fillFieldNameMapping(HashBasedTable<String, String, String> m
146146
public static String dealDuplicateFieldName(HashBasedTable<String, String, String> mappingTable, String fieldName) {
147147
String mappingFieldName = fieldName;
148148
int index = 0;
149-
String originalVal = fieldName;
150-
while (!mappingTable.column(originalVal).isEmpty() && (mappingTable.column(originalVal).containsValue(fieldName) || !mappingTable.column(fieldName).isEmpty())) {
151-
mappingFieldName = originalVal + index;
152-
fieldName = fieldName + index;
149+
while (!mappingTable.column(mappingFieldName).isEmpty()) {
150+
mappingFieldName = mappingFieldName + index;
153151
index++;
154152
}
155153
return mappingFieldName;

0 commit comments

Comments
 (0)