(seatunnel) branch dev updated: [Hotfix][Oracle-CDC] Fix jdbc setFetchSize error (#6210)

[wanghailin]

This is an automated email from the ASF dual-hosted git repository.

wanghailin pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new b7f06ec6d9 [Hotfix][Oracle-CDC] Fix jdbc setFetchSize error (#6210)
b7f06ec6d9 is described below

commit b7f06ec6d9483d910e298bb2a2e9effc28a530b6
Author: hailin0 <wanghai...@apache.org>
AuthorDate: Mon Jan 15 23:09:43 2024 +0800

    [Hotfix][Oracle-CDC] Fix jdbc setFetchSize error (#6210)
---
 .../seatunnel/connectors/seatunnel/cdc/oracle/utils/OracleUtils.java  | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/utils/OracleUtils.java
 
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/utils/OracleUtils.java
index d5f9d9a8fb..89e843c393 100644
--- 
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/utils/OracleUtils.java
+++ 
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/utils/OracleUtils.java
@@ -56,6 +56,8 @@ import java.util.Optional;
 @Slf4j
 public class OracleUtils {
 
+    private static final int DEFAULT_FETCH_SIZE = 1024;
+
     private OracleUtils() {}
 
     public static Object[] queryMinMax(JdbcConnection jdbc, TableId tableId, 
String columnName)
@@ -162,7 +164,7 @@ public class OracleUtils {
                             .createStatement(
                                     ResultSet.TYPE_FORWARD_ONLY, 
ResultSet.CONCUR_READ_ONLY);
 
-            stmt.setFetchSize(Integer.MIN_VALUE);
+            stmt.setFetchSize(DEFAULT_FETCH_SIZE);
             rs = stmt.executeQuery(sampleQuery);
 
             int count = 0;