fix

Author: dapeng

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

@@ -110,6 +110,14 @@ protected void parseCacheProp(AbstractSideTableInfo sideTableInfo, Map<String, O
                 sideTableInfo.setAsyncTimeout(asyncTimeout);
             }
 
+            if(props.containsKey(AbstractSideTableInfo.ASYNC_FAIL_MAX_NUM_KEY.toLowerCase())){
+                Long asyncFailMaxNum = MathUtil.getLongVal(props.get(AbstractSideTableInfo.ASYNC_FAIL_MAX_NUM_KEY.toLowerCase()));
+                if (asyncFailMaxNum<0){
+                    throw new RuntimeException("asyncFailMaxNum need > 0.");
+                }
+                sideTableInfo.setAsyncFailMaxNum(asyncFailMaxNum);
+            }
+
             if(props.containsKey(AbstractSideTableInfo.CONNECT_RETRY_MAX_NUM_KEY.toLowerCase())){
                 Integer connectRetryMaxNum = MathUtil.getIntegerVal(props.get(AbstractSideTableInfo.CONNECT_RETRY_MAX_NUM_KEY.toLowerCase()));
                 if (connectRetryMaxNum > 0){