Merge branch 'hotfix_1.8_3.10.x_30118' into hotfix_1.8_3.10.x_29968

Author: lvyanquan

flinkx-phoenix/flinkx-phoenix-reader/src/main/java/com/dtstack/flinkx/phoenix/format/PhoenixInputFormat.java

@@ -96,7 +96,7 @@ public void openInternal(InputSplit inputSplit) throws IOException {
 
             statement = dbConn.createStatement(resultSetType, resultSetConcurrency);
 
-            statement.setFetchSize(databaseInterface.getFetchSize());
+            statement.setFetchSize(fetchSize);
 
             statement.setQueryTimeout(queryTimeOut);
             String querySql = buildQuerySql(inputSplit);

flinkx-phoenix5/flinkx-phoenix5-reader/src/main/java/com/dtstack/flinkx/phoenix5/format/Phoenix5InputFormat.java

@@ -96,7 +96,7 @@ public void openInternal(InputSplit inputSplit) throws IOException {
 
             statement = dbConn.createStatement(resultSetType, resultSetConcurrency);
 
-            statement.setFetchSize(databaseInterface.getFetchSize());
+            statement.setFetchSize(fetchSize);
 
             statement.setQueryTimeout(queryTimeOut);
             String querySql = buildQuerySql(inputSplit);