Skip to content

Commit 4099312

Browse files
committed
Merge branch 'feat_1.8_async' into 'feat_async_mergedDev'
默认初始值不限制 See merge request !253
2 parents e2f3e5f + 565834e commit 4099312

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

core/src/main/java/com/dtstack/flink/sql/side/SideTableInfo.java

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

6666
private int asyncTimeout=10000;
6767

68-
private int asyncTimeoutNumLimit = 0;
68+
private int asyncTimeoutNumLimit = Integer.MAX_VALUE;
6969

7070
private boolean partitionedJoin = false;
7171

0 commit comments

Comments
 (0)