【 使用环境 】测试环境
【 OB or 其他组件 】OMS
【 使用版本 】OMS 4.2.3
【问题描述】OMS任务报错，但是，看不出错误在哪里。
【复现路径】目前OMS延时，数据无更新，尝试重启任务，任务会卡在14点14分左右。
【附件及日志】
972
at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60)
973
at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25)
974
at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47)
975
at java.lang.Thread.run(Thread.java:853)
976
[2024-05-13 15:40:37.770] [ERROR] [sinkTask-9] [recyle error]
977
java.sql.SQLNonTransientConnectionException: (conn=3221671241) Connection is closed
978
at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.createException(ExceptionFactory.java:122)
979
at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.create(ExceptionFactory.java:230)
980
at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.cmdPrologue(AbstractQueryProtocol.java:2621)
981
at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:311)
982
at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:298)
983
at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.setAutoCommit(AbstractQueryProtocol.java:1959)
984
at com.oceanbase.jdbc.OceanBaseConnection.setAutoCommit(OceanBaseConnection.java:969)
985
at com.alibaba.druid.pool.DruidConnectionHolder.reset(DruidConnectionHolder.java:312)
986
at com.alibaba.druid.pool.DruidDataSource.recycle(DruidDataSource.java:1949)
987
at com.alibaba.druid.pool.DruidPooledConnection.recycle(DruidPooledConnection.java:351)
988
at com.alibaba.druid.pool.DruidPooledConnection.close(DruidPooledConnection.java:288)
989
at com.oceanbase.oms.connector.jdbc.sink.AbstractDruidDataSourceBuilder.closeConnection(AbstractDruidDataSourceBuilder.java:46)
990
at com.oceanbase.oms.connector.jdbc.sink.Writer.closeConnection(Writer.java:753)
991
at com.oceanbase.oms.connector.jdbc.sink.Writer.resetConnection(Writer.java:734)
992
at com.oceanbase.oms.connector.jdbc.sink.Writer.handleRetry(Writer.java:711)
993
at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:513)
994
at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDML(Writer.java:395)
995
at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:287)
996
at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193)
997
at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60)
998
at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25)
999
at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47)
1000
at java.lang.Thread.run(Thread.java:853)
CY
同样的错误，看不出啥问题，数据也同步过来了，后面就自己恢复了，好像也没啥影响