(seatunnel) branch dev updated: [Improve] JdbcInputFormat nextRecord Exception throw TableId (#9374)

[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 484aef593d [Improve] JdbcInputFormat nextRecord Exception throw 
TableId (#9374)
484aef593d is described below

commit 484aef593d6ce92284e92cf1b0c54f4f132d7d7a
Author: Zhilin Li <zhilinli0...@gmail.com>
AuthorDate: Tue Jun 3 23:03:37 2025 +0800

    [Improve] JdbcInputFormat nextRecord Exception throw TableId (#9374)
---
 .../connectors/seatunnel/jdbc/internal/JdbcInputFormat.java       | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/JdbcInputFormat.java
 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/JdbcInputFormat.java
index a6e12ad6bf..90dbe021fc 100644
--- 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/JdbcInputFormat.java
+++ 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/JdbcInputFormat.java
@@ -155,12 +155,16 @@ public class JdbcInputFormat implements Serializable {
         } catch (SQLException se) {
             throw new JdbcConnectorException(
                     CommonErrorCodeDeprecated.SQL_OPERATION_FAILED,
-                    "Couldn't read data - " + se.getMessage(),
+                    String.format(
+                            "Failed to read data from table '%s': %s",
+                            splitTableId, se.getMessage()),
                     se);
         } catch (NullPointerException npe) {
             throw new JdbcConnectorException(
                     CommonErrorCodeDeprecated.SQL_OPERATION_FAILED,
-                    "Couldn't access resultSet",
+                    String.format(
+                            "Failed to access resultSet for table '%s': 
NullPointerException occurred",
+                            splitTableId),
                     npe);
         }
     }