Skip to content

Commit a87b79e

Browse files
committed
Merge branch '1.5_dev_paralams' into 'v1.5.0_dev'
default parallelism is -1 See merge request !125
2 parents 97977ce + fbcf071 commit a87b79e

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -59,7 +59,7 @@ public abstract class TableInfo implements Serializable {
5959

6060
private List<String> primaryKeys;
6161

62-
private Integer parallelism = 1;
62+
private Integer parallelism = -1;
6363

6464
public String[] getFieldTypes() {
6565
return fieldTypes;

0 commit comments

Comments
 (0)