NaughtyYang commented on issue #11769:
URL: https://github.com/apache/seatunnel/issues/11769#issuecomment-5313062496
[1139833582773075969] 2026-08-16 00:30:04,931 WARN
[.a.s.s.c.z.h.p.ProxyConnection] [st-multi-table-sink-writer-2] - HikariPool-82
- Connection com.mysql.cj.jdbc.ConnectionImpl@680d5258 marked as broken because
of SQLSTATE(08S01), ErrorCode(0)
com.mysql.cj.jdbc.exceptions.CommunicationsException: The last packet
successfully received from the server was 84,340,459 milliseconds ago. The last
packet sent successfully to the server was 84,340,479 milliseconds ago. is
longer than the server configured value of 'wait_timeout'. You should consider
either expiring and/or testing connection validity before use in your
application, increasing the server configured values for client timeouts, or
using the Connector/J connection property 'autoReconnect=true' to avoid this
problem.
at
com.mysql.cj.jdbc.exceptions.SQLError.createCommunicationsException(SQLError.java:174)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:64)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.jdbc.ConnectionImpl.isReadOnly(ConnectionImpl.java:1403)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.jdbc.ConnectionImpl.isReadOnly(ConnectionImpl.java:1388)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.jdbc.ClientPreparedStatement.executeBatchInternal(ClientPreparedStatement.java:403)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at com.mysql.cj.jdbc.StatementImpl.executeBatch(StatementImpl.java:800)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
org.apache.seatunnel.shade.com.zaxxer.hikari.pool.ProxyStatement.executeBatch(ProxyStatement.java:127)
~[?:?]
at
org.apache.seatunnel.shade.com.zaxxer.hikari.pool.HikariProxyPreparedStatement.executeBatch(HikariProxyPreparedStatement.java)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.FieldNamedPreparedStatement.executeBatch(FieldNamedPreparedStatement.java:540)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.SimpleBatchStatementExecutor.executeBatch(SimpleBatchStatementExecutor.java:54)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.BufferReducedBatchStatementExecutor.executeBatch(BufferReducedBatchStatementExecutor.java:80)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.JdbcOutputFormat.attemptFlush(JdbcOutputFormat.java:172)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.JdbcOutputFormat.flush(JdbcOutputFormat.java:136)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.JdbcOutputFormat.writeRecord(JdbcOutputFormat.java:106)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.sink.JdbcSinkWriter.write(JdbcSinkWriter.java:154)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.sink.JdbcSinkWriter.write(JdbcSinkWriter.java:44)
~[?:?]
at
org.apache.seatunnel.api.sink.multitablesink.MultiTableWriterRunnable.run(MultiTableWriterRunnable.java:67)
~[seatunnel-starter.jar:2.3.12]
at
org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:43)
~[seatunnel-starter.jar:2.3.12]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
~[?:1.8.0_272]
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
~[?:1.8.0_272]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
~[?:1.8.0_272]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
~[?:1.8.0_272]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_272]
Caused by: com.mysql.cj.exceptions.CJCommunicationsException: The last
packet successfully received from the server was 84,340,459 milliseconds ago.
The last packet sent successfully to the server was 84,340,479 milliseconds
ago. is longer than the server configured value of 'wait_timeout'. You should
consider either expiring and/or testing connection validity before use in your
application, increasing the server configured values for client timeouts, or
using the Connector/J connection property 'autoReconnect=true' to avoid this
problem.
at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native
Method) ~[?:1.8.0_272]
at
sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
~[?:1.8.0_272]
at
sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
~[?:1.8.0_272]
at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
~[?:1.8.0_272]
at
com.mysql.cj.exceptions.ExceptionFactory.createException(ExceptionFactory.java:61)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.exceptions.ExceptionFactory.createException(ExceptionFactory.java:105)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.exceptions.ExceptionFactory.createException(ExceptionFactory.java:151)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.exceptions.ExceptionFactory.createCommunicationsException(ExceptionFactory.java:167)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at com.mysql.cj.protocol.a.NativeProtocol.send(NativeProtocol.java:567)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.protocol.a.NativeProtocol.sendCommand(NativeProtocol.java:622)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.protocol.a.NativeProtocol.sendCommand(NativeProtocol.java:137)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at com.mysql.cj.NativeSession.sendCommand(NativeSession.java:279)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.NativeSession.queryServerVariable(NativeSession.java:599)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.jdbc.ConnectionImpl.isReadOnly(ConnectionImpl.java:1395)
~[mysql-connector-java-8.0.27.jar:8.0.27]
... 20 more
Caused by: java.net.SocketException: Broken pipe (Write failed)
at java.net.SocketOutputStream.socketWrite0(Native Method)
~[?:1.8.0_272]
at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:111)
~[?:1.8.0_272]
at java.net.SocketOutputStream.write(SocketOutputStream.java:155)
~[?:1.8.0_272]
at
java.io.BufferedOutputStream.flushBuffer(BufferedOutputStream.java:82)
~[?:1.8.0_272]
at java.io.BufferedOutputStream.flush(BufferedOutputStream.java:140)
~[?:1.8.0_272]
at
com.mysql.cj.protocol.a.SimplePacketSender.send(SimplePacketSender.java:55)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.protocol.a.TimeTrackingPacketSender.send(TimeTrackingPacketSender.java:50)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at com.mysql.cj.protocol.a.NativeProtocol.send(NativeProtocol.java:558)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.protocol.a.NativeProtocol.sendCommand(NativeProtocol.java:622)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.protocol.a.NativeProtocol.sendCommand(NativeProtocol.java:137)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at com.mysql.cj.NativeSession.sendCommand(NativeSession.java:279)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.NativeSession.queryServerVariable(NativeSession.java:599)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.jdbc.ConnectionImpl.isReadOnly(ConnectionImpl.java:1395)
~[mysql-connector-java-8.0.27.jar:8.0.27]
... 20 more
[1139833582773075969] 2026-08-16 00:30:04,934 ERROR
[o.a.s.c.s.j.i.JdbcOutputFormat] [st-multi-table-sink-writer-2] - JDBC
executeBatch error, retry times = 0
com.mysql.cj.jdbc.exceptions.CommunicationsException: The last packet
successfully received from the server was 84,340,459 milliseconds ago. The last
packet sent successfully to the server was 84,340,479 milliseconds ago. is
longer than the server configured value of 'wait_timeout'. You should consider
either expiring and/or testing connection validity before use in your
application, increasing the server configured values for client timeouts, or
using the Connector/J connection property 'autoReconnect=true' to avoid this
problem.
at
com.mysql.cj.jdbc.exceptions.SQLError.createCommunicationsException(SQLError.java:174)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:64)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.jdbc.ConnectionImpl.isReadOnly(ConnectionImpl.java:1403)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.jdbc.ConnectionImpl.isReadOnly(ConnectionImpl.java:1388)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.jdbc.ClientPreparedStatement.executeBatchInternal(ClientPreparedStatement.java:403)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at com.mysql.cj.jdbc.StatementImpl.executeBatch(StatementImpl.java:800)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
org.apache.seatunnel.shade.com.zaxxer.hikari.pool.ProxyStatement.executeBatch(ProxyStatement.java:127)
~[?:?]
at
org.apache.seatunnel.shade.com.zaxxer.hikari.pool.HikariProxyPreparedStatement.executeBatch(HikariProxyPreparedStatement.java)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.FieldNamedPreparedStatement.executeBatch(FieldNamedPreparedStatement.java:540)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.SimpleBatchStatementExecutor.executeBatch(SimpleBatchStatementExecutor.java:54)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.BufferReducedBatchStatementExecutor.executeBatch(BufferReducedBatchStatementExecutor.java:80)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.JdbcOutputFormat.attemptFlush(JdbcOutputFormat.java:172)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.JdbcOutputFormat.flush(JdbcOutputFormat.java:136)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.JdbcOutputFormat.writeRecord(JdbcOutputFormat.java:106)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.sink.JdbcSinkWriter.write(JdbcSinkWriter.java:154)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.sink.JdbcSinkWriter.write(JdbcSinkWriter.java:44)
~[?:?]
at
org.apache.seatunnel.api.sink.multitablesink.MultiTableWriterRunnable.run(MultiTableWriterRunnable.java:67)
~[seatunnel-starter.jar:2.3.12]
at
org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:43)
~[seatunnel-starter.jar:2.3.12]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
~[?:1.8.0_272]
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
~[?:1.8.0_272]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
~[?:1.8.0_272]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
~[?:1.8.0_272]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_272]
Caused by: com.mysql.cj.exceptions.CJCommunicationsException: The last
packet successfully received from the server was 84,340,459 milliseconds ago.
The last packet sent successfully to the server was 84,340,479 milliseconds
ago. is longer than the server configured value of 'wait_timeout'. You should
consider either expiring and/or testing connection validity before use in your
application, increasing the server configured values for client timeouts, or
using the Connector/J connection property 'autoReconnect=true' to avoid this
problem.
at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native
Method) ~[?:1.8.0_272]
at
sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
~[?:1.8.0_272]
at
sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
~[?:1.8.0_272]
at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
~[?:1.8.0_272]
at
com.mysql.cj.exceptions.ExceptionFactory.createException(ExceptionFactory.java:61)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.exceptions.ExceptionFactory.createException(ExceptionFactory.java:105)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.exceptions.ExceptionFactory.createException(ExceptionFactory.java:151)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.exceptions.ExceptionFactory.createCommunicationsException(ExceptionFactory.java:167)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at com.mysql.cj.protocol.a.NativeProtocol.send(NativeProtocol.java:567)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.protocol.a.NativeProtocol.sendCommand(NativeProtocol.java:622)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.protocol.a.NativeProtocol.sendCommand(NativeProtocol.java:137)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at com.mysql.cj.NativeSession.sendCommand(NativeSession.java:279)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.NativeSession.queryServerVariable(NativeSession.java:599)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.jdbc.ConnectionImpl.isReadOnly(ConnectionImpl.java:1395)
~[mysql-connector-java-8.0.27.jar:8.0.27]
... 20 more
Caused by: java.net.SocketException: Broken pipe (Write failed)
at java.net.SocketOutputStream.socketWrite0(Native Method)
~[?:1.8.0_272]
at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:111)
~[?:1.8.0_272]
at java.net.SocketOutputStream.write(SocketOutputStream.java:155)
~[?:1.8.0_272]
at
java.io.BufferedOutputStream.flushBuffer(BufferedOutputStream.java:82)
~[?:1.8.0_272]
at java.io.BufferedOutputStream.flush(BufferedOutputStream.java:140)
~[?:1.8.0_272]
at
com.mysql.cj.protocol.a.SimplePacketSender.send(SimplePacketSender.java:55)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.protocol.a.TimeTrackingPacketSender.send(TimeTrackingPacketSender.java:50)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at com.mysql.cj.protocol.a.NativeProtocol.send(NativeProtocol.java:558)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.protocol.a.NativeProtocol.sendCommand(NativeProtocol.java:622)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.protocol.a.NativeProtocol.sendCommand(NativeProtocol.java:137)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at com.mysql.cj.NativeSession.sendCommand(NativeSession.java:279)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.NativeSession.queryServerVariable(NativeSession.java:599)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.jdbc.ConnectionImpl.isReadOnly(ConnectionImpl.java:1395)
~[mysql-connector-java-8.0.27.jar:8.0.27]
... 20 more
[1139833582773075969] 2026-08-16 00:30:04,939 ERROR
[o.a.s.c.s.j.i.JdbcOutputFormat] [st-multi-table-sink-writer-2] - JDBC
connection is not valid, and reestablish connection failed.
org.apache.seatunnel.connectors.seatunnel.jdbc.exception.JdbcConnectorException:
ErrorCode:[JDBC-10], ErrorDescription:[Data type cast failed] - error
field:descendant
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.converter.AbstractJdbcRowConverter.toExternal(AbstractJdbcRowConverter.java:225)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.SimpleBatchStatementExecutor.addToBatch(SimpleBatchStatementExecutor.java:48)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.SimpleBatchStatementExecutor.addToBatch(SimpleBatchStatementExecutor.java:33)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.BufferReducedBatchStatementExecutor.executeBatch(BufferReducedBatchStatementExecutor.java:77)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.BufferReducedBatchStatementExecutor.closeStatements(BufferReducedBatchStatementExecutor.java:101)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.JdbcOutputFormat.updateExecutor(JdbcOutputFormat.java:207)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.JdbcOutputFormat.flush(JdbcOutputFormat.java:147)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.JdbcOutputFormat.writeRecord(JdbcOutputFormat.java:106)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.sink.JdbcSinkWriter.write(JdbcSinkWriter.java:154)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.sink.JdbcSinkWriter.write(JdbcSinkWriter.java:44)
~[?:?]
at
org.apache.seatunnel.api.sink.multitablesink.MultiTableWriterRunnable.run(MultiTableWriterRunnable.java:67)
~[seatunnel-starter.jar:2.3.12]
at
org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:43)
~[seatunnel-starter.jar:2.3.12]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
~[?:1.8.0_272]
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
~[?:1.8.0_272]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
~[?:1.8.0_272]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
~[?:1.8.0_272]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_272]
Caused by: java.sql.SQLException: No operations allowed after statement
closed.
at
com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:129)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:97)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:89)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:63)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:73)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:82)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.jdbc.ClientPreparedStatement.checkBounds(ClientPreparedStatement.java:1405)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.jdbc.ClientPreparedStatement.getCoreParameterIndex(ClientPreparedStatement.java:1409)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.jdbc.ClientPreparedStatement.setInt(ClientPreparedStatement.java:1597)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
org.apache.seatunnel.shade.com.zaxxer.hikari.pool.HikariProxyPreparedStatement.setInt(HikariProxyPreparedStatement.java)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.FieldNamedPreparedStatement.setInt(FieldNamedPreparedStatement.java:95)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.converter.AbstractJdbcRowConverter.setValueToStatementByDataType(AbstractJdbcRowConverter.java:253)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.converter.AbstractJdbcRowConverter.toExternal(AbstractJdbcRowConverter.java:216)
~[?:?]
... 16 more
Caused by: com.mysql.cj.exceptions.StatementIsClosedException: No operations
allowed after statement closed.
at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native
Method) ~[?:1.8.0_272]
at
sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
~[?:1.8.0_272]
at
sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
~[?:1.8.0_272]
at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
~[?:1.8.0_272]
at
com.mysql.cj.exceptions.ExceptionFactory.createException(ExceptionFactory.java:61)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.exceptions.ExceptionFactory.createException(ExceptionFactory.java:85)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at com.mysql.cj.jdbc.StatementImpl.checkClosed(StatementImpl.java:341)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.jdbc.ClientPreparedStatement.checkBounds(ClientPreparedStatement.java:1391)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.jdbc.ClientPreparedStatement.getCoreParameterIndex(ClientPreparedStatement.java:1409)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.jdbc.ClientPreparedStatement.setInt(ClientPreparedStatement.java:1597)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
org.apache.seatunnel.shade.com.zaxxer.hikari.pool.HikariProxyPreparedStatement.setInt(HikariProxyPreparedStatement.java)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.FieldNamedPreparedStatement.setInt(FieldNamedPreparedStatement.java:95)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.converter.AbstractJdbcRowConverter.setValueToStatementByDataType(AbstractJdbcRowConverter.java:253)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.converter.AbstractJdbcRowConverter.toExternal(AbstractJdbcRowConverter.java:216)
~[?:?]
... 16 more
[1139833582773075969] 2026-08-16 00:30:04,939 ERROR
[a.s.m.MultiTableWriterRunnable] [st-multi-table-sink-writer-2] -
MultiTableWriterRunnable error when write row
SeaTunnelRow{tableId=base_bank_server.bank_dept_relation, kind=-D,
fields=[7497, 7678]}
org.apache.seatunnel.connectors.seatunnel.jdbc.exception.JdbcConnectorException:
ErrorCode:[COMMON-08], ErrorDescription:[Sql operation failed, such as
(execute,addBatch,close) etc...] - Writing records to JDBC failed.
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.JdbcOutputFormat.writeRecord(JdbcOutputFormat.java:109)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.sink.JdbcSinkWriter.write(JdbcSinkWriter.java:154)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.sink.JdbcSinkWriter.write(JdbcSinkWriter.java:44)
~[?:?]
at
org.apache.seatunnel.api.sink.multitablesink.MultiTableWriterRunnable.run(MultiTableWriterRunnable.java:67)
~[seatunnel-starter.jar:2.3.12]
at
org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:43)
~[seatunnel-starter.jar:2.3.12]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
~[?:1.8.0_272]
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
~[?:1.8.0_272]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
~[?:1.8.0_272]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
~[?:1.8.0_272]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_272]
Caused by:
org.apache.seatunnel.connectors.seatunnel.jdbc.exception.JdbcConnectorException:
ErrorCode:[JDBC-04], ErrorDescription:[Connector database failed] -
Reestablish JDBC connection failed
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.JdbcOutputFormat.flush(JdbcOutputFormat.java:153)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.JdbcOutputFormat.writeRecord(JdbcOutputFormat.java:106)
~[?:?]
... 9 more
Caused by:
org.apache.seatunnel.connectors.seatunnel.jdbc.exception.JdbcConnectorException:
ErrorCode:[JDBC-10], ErrorDescription:[Data type cast failed] - error
field:descendant
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.converter.AbstractJdbcRowConverter.toExternal(AbstractJdbcRowConverter.java:225)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.SimpleBatchStatementExecutor.addToBatch(SimpleBatchStatementExecutor.java:48)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.SimpleBatchStatementExecutor.addToBatch(SimpleBatchStatementExecutor.java:33)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.BufferReducedBatchStatementExecutor.executeBatch(BufferReducedBatchStatementExecutor.java:77)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.BufferReducedBatchStatementExecutor.closeStatements(BufferReducedBatchStatementExecutor.java:101)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.JdbcOutputFormat.updateExecutor(JdbcOutputFormat.java:207)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.JdbcOutputFormat.flush(JdbcOutputFormat.java:147)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.JdbcOutputFormat.writeRecord(JdbcOutputFormat.java:106)
~[?:?]
... 9 more
Caused by: java.sql.SQLException: No operations allowed after statement
closed.
at
com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:129)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:97)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:89)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:63)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:73)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:82)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.jdbc.ClientPreparedStatement.checkBounds(ClientPreparedStatement.java:1405)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.jdbc.ClientPreparedStatement.getCoreParameterIndex(ClientPreparedStatement.java:1409)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.jdbc.ClientPreparedStatement.setInt(ClientPreparedStatement.java:1597)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
org.apache.seatunnel.shade.com.zaxxer.hikari.pool.HikariProxyPreparedStatement.setInt(HikariProxyPreparedStatement.java)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.FieldNamedPreparedStatement.setInt(FieldNamedPreparedStatement.java:95)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.converter.AbstractJdbcRowConverter.setValueToStatementByDataType(AbstractJdbcRowConverter.java:253)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.converter.AbstractJdbcRowConverter.toExternal(AbstractJdbcRowConverter.java:216)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.SimpleBatchStatementExecutor.addToBatch(SimpleBatchStatementExecutor.java:48)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.SimpleBatchStatementExecutor.addToBatch(SimpleBatchStatementExecutor.java:33)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.BufferReducedBatchStatementExecutor.executeBatch(BufferReducedBatchStatementExecutor.java:77)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.BufferReducedBatchStatementExecutor.closeStatements(BufferReducedBatchStatementExecutor.java:101)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.JdbcOutputFormat.updateExecutor(JdbcOutputFormat.java:207)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.JdbcOutputFormat.flush(JdbcOutputFormat.java:147)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.JdbcOutputFormat.writeRecord(JdbcOutputFormat.java:106)
~[?:?]
... 9 more
Caused by: com.mysql.cj.exceptions.StatementIsClosedException: No operations
allowed after statement closed.
at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native
Method) ~[?:1.8.0_272]
at
sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
~[?:1.8.0_272]
at
sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
~[?:1.8.0_272]
at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
~[?:1.8.0_272]
at
com.mysql.cj.exceptions.ExceptionFactory.createException(ExceptionFactory.java:61)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.exceptions.ExceptionFactory.createException(ExceptionFactory.java:85)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at com.mysql.cj.jdbc.StatementImpl.checkClosed(StatementImpl.java:341)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.jdbc.ClientPreparedStatement.checkBounds(ClientPreparedStatement.java:1391)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.jdbc.ClientPreparedStatement.getCoreParameterIndex(ClientPreparedStatement.java:1409)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
com.mysql.cj.jdbc.ClientPreparedStatement.setInt(ClientPreparedStatement.java:1597)
~[mysql-connector-java-8.0.27.jar:8.0.27]
at
org.apache.seatunnel.shade.com.zaxxer.hikari.pool.HikariProxyPreparedStatement.setInt(HikariProxyPreparedStatement.java)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.FieldNamedPreparedStatement.setInt(FieldNamedPreparedStatement.java:95)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.converter.AbstractJdbcRowConverter.setValueToStatementByDataType(AbstractJdbcRowConverter.java:253)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.converter.AbstractJdbcRowConverter.toExternal(AbstractJdbcRowConverter.java:216)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.SimpleBatchStatementExecutor.addToBatch(SimpleBatchStatementExecutor.java:48)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.SimpleBatchStatementExecutor.addToBatch(SimpleBatchStatementExecutor.java:33)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.BufferReducedBatchStatementExecutor.executeBatch(BufferReducedBatchStatementExecutor.java:77)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.executor.BufferReducedBatchStatementExecutor.closeStatements(BufferReducedBatchStatementExecutor.java:101)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.JdbcOutputFormat.updateExecutor(JdbcOutputFormat.java:207)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.JdbcOutputFormat.flush(JdbcOutputFormat.java:147)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.JdbcOutputFormat.writeRecord(JdbcOutputFormat.java:106)
~[?:?]
... 9 more
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
