参数赋值错误

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 = Integer.MAX_VALUE;
+    private int asyncTimeoutNumLimit = 0;
 
     private boolean partitionedJoin = false;
 

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

@@ -111,7 +111,7 @@ protected void parseCacheProp(SideTableInfo sideTableInfo, Map<String, Object> p
             if(props.containsKey(SideTableInfo.ASYNC_TIMEOUT_NUM_KEY.toLowerCase())){
                 Integer asyncTimeoutNum = MathUtil.getIntegerVal(props.get(SideTableInfo.ASYNC_TIMEOUT_NUM_KEY.toLowerCase()));
                 if (asyncTimeoutNum > 0){
-                    sideTableInfo.setAsyncTimeout(asyncTimeoutNum);
+                    sideTableInfo.setAsyncTimeoutNumLimit(asyncTimeoutNum);
                 }
             }
         }