默认初始值不限制

Author: dapeng

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

@@ -65,7 +65,7 @@ public abstract class SideTableInfo extends TableInfo implements Serializable {
 
     private int  asyncTimeout=10000;
 
-    private int asyncTimeoutNumLimit = 0;
+    private int asyncTimeoutNumLimit = Integer.MAX_VALUE;
 
     private boolean partitionedJoin = false;