修改初始值和判断逻辑

Author: dapeng

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

@@ -130,6 +130,8 @@ public void timeout(Row input, ResultFuture<Row> resultFuture) throws Exception
         timeOutNum ++;
         if(timeOutNum > sideInfo.getSideTableInfo().getAsyncTimeoutNumLimit()){
             resultFuture.completeExceptionally(new Exception("Async function call timedoutNum beyond limit."));
+        } else {
+            resultFuture.complete(null);
         }
     }
 

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;