并行度修改

Author: simenliuxing

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

@@ -61,7 +61,7 @@ public abstract class TableInfo implements Serializable {
 
     private List<String> primaryKeys;
 
-    private Integer parallelism = 1;
+    private Integer parallelism = -1;
 
     public String[] getFieldTypes() {
         return fieldTypes;