fetchSize修复

Author: kanata163

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(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);