(seatunnel) branch dev updated: [Improve][Connector-V2] Enhance JDBC chunk splitter logging (#10950)

[lidongdai]

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

davidzollo 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 4312d70a41 [Improve][Connector-V2] Enhance JDBC chunk splitter logging 
(#10950)
4312d70a41 is described below

commit 4312d70a413f3cb7c89e6c3ec97cc0bcd9b235ba
Author: Jast <shengh...@apache.org>
AuthorDate: Tue Jun 9 11:18:15 2026 +0800

    [Improve][Connector-V2] Enhance JDBC chunk splitter logging (#10950)
---
 .../connectors/seatunnel/jdbc/source/ChunkSplitter.java   |  2 +-
 .../seatunnel/jdbc/source/DynamicChunkSplitter.java       | 15 +++++++++++++++
 .../seatunnel/jdbc/source/FixedChunkSplitter.java         |  7 +++++++
 3 files changed, 23 insertions(+), 1 deletion(-)

diff --git 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/ChunkSplitter.java
 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/ChunkSplitter.java
index 67750cd70b..000202a4e7 100644
--- 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/ChunkSplitter.java
+++ 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/ChunkSplitter.java
@@ -143,7 +143,7 @@ public abstract class ChunkSplitter implements 
AutoCloseable, Serializable {
         if (connection.getAutoCommit() != autoCommit) {
             connection.setAutoCommit(autoCommit);
         }
-        log.debug("Prepared statement: {}", sql);
+        log.info("Prepared statement: {}", sql);
         return jdbcDialect.creatPreparedStatement(connection, sql, fetchSize);
     }
 
diff --git 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/DynamicChunkSplitter.java
 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/DynamicChunkSplitter.java
index a6c10b8a5e..bafe042ae7 100644
--- 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/DynamicChunkSplitter.java
+++ 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/DynamicChunkSplitter.java
@@ -903,16 +903,31 @@ public class DynamicChunkSplitter extends ChunkSplitter {
                 statement.setObject(i + 1, splitEnd[i]);
                 statement.setObject(i + 1 + splitKeyNumbers, splitEnd[i]);
             }
+            log.info(
+                    "Dynamic split (first) - params: [{}={}, {}={}]",
+                    1,
+                    splitEnd[0],
+                    2,
+                    splitEnd[0]);
         } else if (isLastSplit) {
             for (int i = 0; i < splitKeyNumbers; i++) {
                 statement.setObject(i + 1, splitStart[i]);
             }
+            log.info("Dynamic split (last) - params: [{}={}]", 1, 
splitStart[0]);
         } else {
             for (int i = 0; i < splitKeyNumbers; i++) {
                 statement.setObject(i + 1, splitStart[i]);
                 statement.setObject(i + 1 + splitKeyNumbers, splitEnd[i]);
                 statement.setObject(i + 1 + 2 * splitKeyNumbers, splitEnd[i]);
             }
+            log.info(
+                    "Dynamic split (middle) - params: [{}={}, {}={}, {}={}]",
+                    1,
+                    splitStart[0],
+                    2,
+                    splitEnd[0],
+                    3,
+                    splitEnd[0]);
         }
     }
 
diff --git 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/FixedChunkSplitter.java
 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/FixedChunkSplitter.java
index 309b6c82bd..5ad48e8554 100644
--- 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/FixedChunkSplitter.java
+++ 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/FixedChunkSplitter.java
@@ -341,6 +341,7 @@ public class FixedChunkSplitter extends ChunkSplitter {
             throws SQLException {
         PreparedStatement statement = 
createPreparedStatement(split.getSplitQuery());
         statement.setInt(1, (Integer) split.getSplitStart());
+        log.info("String column split - param[1]: {}", split.getSplitStart());
         return statement;
     }
 
@@ -410,6 +411,12 @@ public class FixedChunkSplitter extends ChunkSplitter {
                 jdbcNumericBetweenParametersProvider.getParameterValues();
         List<JdbcSourceSplit> splits = new 
ArrayList<>(table.getPartitionNumber());
         for (int i = 0; i < parameterValues.length; i++) {
+            log.info(
+                    "Number column split - params: [{}={}, {}={}]",
+                    1,
+                    parameterValues[i][0],
+                    2,
+                    parameterValues[i][1]);
             JdbcSourceSplit split =
                     new JdbcSourceSplit(
                             table.getTablePath(),