Merge branch '1.8_release_3.10.x' into 1.8_release_4.0.x

Author: gituser

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

@@ -68,7 +68,7 @@ public void openInternal(InputSplit inputSplit) throws IOException {
 
             statement = dbConn.createStatement(resultSetType, resultSetConcurrency);
 
-            statement.setFetchSize(0);
+            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(0);
+            statement.setFetchSize(fetchSize);
 
             statement.setQueryTimeout(queryTimeOut);
             String querySql = buildQuerySql(inputSplit);