Merge branch 'hotfix_1.10_4.0.x_32501' into 1.10_release_4.0.x

Author: gituser

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

@@ -23,6 +23,7 @@
 import com.dtstack.flink.sql.enums.ECacheType;
 import com.dtstack.flink.sql.side.AbstractSideTableInfo;
 import com.dtstack.flink.sql.util.MathUtil;
+import org.apache.flink.util.Preconditions;
 
 import java.util.Map;
 import java.util.regex.Matcher;
@@ -124,6 +125,12 @@ protected void parseCacheProp(AbstractSideTableInfo sideTableInfo, Map<String, O
                     sideTableInfo.setConnectRetryMaxNum(connectRetryMaxNum);
                 }
             }
+
+            if (props.containsKey(AbstractSideTableInfo.ASYNC_REQ_POOL_KEY.toLowerCase())) {
+                Integer asyncPoolSize = MathUtil.getIntegerVal(props.get(AbstractSideTableInfo.ASYNC_REQ_POOL_KEY.toLowerCase()));
+                Preconditions.checkArgument(asyncPoolSize > 0 && asyncPoolSize <= 20, "asyncPoolSize size limit (0,20]");
+                sideTableInfo.setAsyncPoolSize(asyncPoolSize);
+            }
         }
     }
 }