Skip to content

Commit 8d6871c

Browse files
committed
[fix-32575][core]修复设置全局并行度后,对算子并行度不生效问题
1 parent 8de2992 commit 8d6871c

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -59,7 +59,7 @@ public abstract class AbstractTableInfo 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)