[fix-32501][core] fix can't set asyncPoolSize.
@@ -23,6 +23,7 @@ package com.dtstack.flink.sql.table;
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 @@ public abstract class AbstractSideTableParser extends AbstractTableParser {
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);
+ }
}
}
}
