We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 97977ce commit fbcf071Copy full SHA for fbcf071
core/src/main/java/com/dtstack/flink/sql/table/TableInfo.java
@@ -59,7 +59,7 @@ public abstract class TableInfo implements Serializable {
59
60
private List<String> primaryKeys;
61
62
- private Integer parallelism = 1;
+ private Integer parallelism = -1;
63
64
public String[] getFieldTypes() {
65
return fieldTypes;
0 commit comments