redundancy field name check

todd5167 · todd5167 · commit 0ee478d24021 · 2019-11-12T15:47:11.000+08:00
diff --git a/core/src/main/java/com/dtstack/flink/sql/table/TableInfo.java b/core/src/main/java/com/dtstack/flink/sql/table/TableInfo.java
@@ -118,6 +118,10 @@ public void setParallelism(Integer parallelism) {
     }
 
     public void addField(String fieldName){
+        if (fieldList.contains(fieldName)) {
+            throw new RuntimeException("redundancy field name " + fieldName + " in table " + getName());
+        }
+
         fieldList.add(fieldName);
     }
 

Original file line number	Diff line number	Diff line change
`@@ -118,6 +118,10 @@ public void setParallelism(Integer parallelism) {`
`118`	`118`	`}`
`119`	`119`
`120`	`120`	`public void addField(String fieldName){`
	`121`	`+ if (fieldList.contains(fieldName)) {`
	`122`	`+ throw new RuntimeException("redundancy field name " + fieldName + " in table " + getName());`
	`123`	`+ }`
	`124`	`+`
`121`	`125`	`fieldList.add(fieldName);`
`122`	`126`	`}`
`123`	`127`