1 [2024-04-01 10:00:42.573] [ERROR] [sinkTask-5] [recyle error] 2 java.sql.SQLNonTransientConnectionException: (conn=3221530869) Connection is closed 3 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.createException(ExceptionFactory.java:122) 4 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.create(ExceptionFactory.java:230) 5 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.cmdPrologue(AbstractQueryProtocol.java:2621) 6 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:311) 7 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:298) 8 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.setAutoCommit(AbstractQueryProtocol.java:1959) 9 at com.oceanbase.jdbc.OceanBaseConnection.setAutoCommit(OceanBaseConnection.java:969) 10 at com.alibaba.druid.pool.DruidConnectionHolder.reset(DruidConnectionHolder.java:312) 11 at com.alibaba.druid.pool.DruidDataSource.recycle(DruidDataSource.java:1949) 12 at com.alibaba.druid.pool.DruidPooledConnection.recycle(DruidPooledConnection.java:351) 13 at com.alibaba.druid.pool.DruidPooledConnection.close(DruidPooledConnection.java:288) 14 at com.oceanbase.oms.connector.jdbc.sink.AbstractDruidDataSourceBuilder.closeConnection(AbstractDruidDataSourceBuilder.java:46) 15 at com.oceanbase.oms.connector.jdbc.sink.Writer.closeConnection(Writer.java:753) 16 at com.oceanbase.oms.connector.jdbc.sink.Writer.resetConnection(Writer.java:734) 17 at com.oceanbase.oms.connector.jdbc.sink.Writer.handleRetry(Writer.java:711) 18 at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:513) 19 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDML(Writer.java:395) 20 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:287) 21 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 22 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 23 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 24 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 25 at java.lang.Thread.run(Thread.java:853) 26 [2024-04-01 10:01:34.740] [ERROR] [sinkTask-5] [recyle error] 27 java.sql.SQLNonTransientConnectionException: (conn=3221536137) Connection is closed 28 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.createException(ExceptionFactory.java:122) 29 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.create(ExceptionFactory.java:230) 30 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.cmdPrologue(AbstractQueryProtocol.java:2621) 31 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:311) 32 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:298) 33 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.setAutoCommit(AbstractQueryProtocol.java:1959) 34 at com.oceanbase.jdbc.OceanBaseConnection.setAutoCommit(OceanBaseConnection.java:969) 35 at com.alibaba.druid.pool.DruidConnectionHolder.reset(DruidConnectionHolder.java:312) 36 at com.alibaba.druid.pool.DruidDataSource.recycle(DruidDataSource.java:1949) 37 at com.alibaba.druid.pool.DruidPooledConnection.recycle(DruidPooledConnection.java:351) 38 at com.alibaba.druid.pool.DruidPooledConnection.close(DruidPooledConnection.java:288) 39 at com.oceanbase.oms.connector.jdbc.sink.AbstractDruidDataSourceBuilder.closeConnection(AbstractDruidDataSourceBuilder.java:46) 40 at com.oceanbase.oms.connector.jdbc.sink.Writer.closeConnection(Writer.java:753) 41 at com.oceanbase.oms.connector.jdbc.sink.Writer.resetConnection(Writer.java:734) 42 at com.oceanbase.oms.connector.jdbc.sink.Writer.handleRetry(Writer.java:711) 43 at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:513) 44 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDML(Writer.java:395) 45 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:287) 46 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 47 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 48 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 49 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 50 at java.lang.Thread.run(Thread.java:853) 51 [2024-04-01 10:02:26.331] [ERROR] [sinkTask-5] [recyle error] 52 java.sql.SQLNonTransientConnectionException: (conn=3221543569) Connection is closed 53 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.createException(ExceptionFactory.java:122) 54 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.create(ExceptionFactory.java:230) 55 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.cmdPrologue(AbstractQueryProtocol.java:2621) 56 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:311) 57 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:298) 58 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.setAutoCommit(AbstractQueryProtocol.java:1959) 59 at com.oceanbase.jdbc.OceanBaseConnection.setAutoCommit(OceanBaseConnection.java:969) 60 at com.alibaba.druid.pool.DruidConnectionHolder.reset(DruidConnectionHolder.java:312) 61 at com.alibaba.druid.pool.DruidDataSource.recycle(DruidDataSource.java:1949) 62 at com.alibaba.druid.pool.DruidPooledConnection.recycle(DruidPooledConnection.java:351) 63 at com.alibaba.druid.pool.DruidPooledConnection.close(DruidPooledConnection.java:288) 64 at com.oceanbase.oms.connector.jdbc.sink.AbstractDruidDataSourceBuilder.closeConnection(AbstractDruidDataSourceBuilder.java:46) 65 at com.oceanbase.oms.connector.jdbc.sink.Writer.closeConnection(Writer.java:753) 66 at com.oceanbase.oms.connector.jdbc.sink.Writer.resetConnection(Writer.java:734) 67 at com.oceanbase.oms.connector.jdbc.sink.Writer.handleRetry(Writer.java:711) 68 at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:513) 69 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDML(Writer.java:395) 70 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:287) 71 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 72 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 73 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 74 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 75 at java.lang.Thread.run(Thread.java:853) 76 [2024-04-01 10:03:18.103] [ERROR] [sinkTask-5] [recyle error] 77 java.sql.SQLNonTransientConnectionException: (conn=3221543900) Connection is closed 78 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.createException(ExceptionFactory.java:122) 79 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.create(ExceptionFactory.java:230) 80 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.cmdPrologue(AbstractQueryProtocol.java:2621) 81 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:311) 82 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:298) 83 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.setAutoCommit(AbstractQueryProtocol.java:1959) 84 at com.oceanbase.jdbc.OceanBaseConnection.setAutoCommit(OceanBaseConnection.java:969) 85 at com.alibaba.druid.pool.DruidConnectionHolder.reset(DruidConnectionHolder.java:312) 86 at com.alibaba.druid.pool.DruidDataSource.recycle(DruidDataSource.java:1949) 87 at com.alibaba.druid.pool.DruidPooledConnection.recycle(DruidPooledConnection.java:351) 88 at com.alibaba.druid.pool.DruidPooledConnection.close(DruidPooledConnection.java:288) 89 at com.oceanbase.oms.connector.jdbc.sink.AbstractDruidDataSourceBuilder.closeConnection(AbstractDruidDataSourceBuilder.java:46) 90 at com.oceanbase.oms.connector.jdbc.sink.Writer.closeConnection(Writer.java:753) 91 at com.oceanbase.oms.connector.jdbc.sink.Writer.resetConnection(Writer.java:734) 92 at com.oceanbase.oms.connector.jdbc.sink.Writer.handleRetry(Writer.java:711) 93 at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:513) 94 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDML(Writer.java:395) 95 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:287) 96 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 97 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 98 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 99 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 100 at java.lang.Thread.run(Thread.java:853) 101 [2024-04-01 10:04:10.628] [ERROR] [sinkTask-5] [recyle error] 102 java.sql.SQLNonTransientConnectionException: (conn=3221555104) Connection is closed 103 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.createException(ExceptionFactory.java:122) 104 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.create(ExceptionFactory.java:230) 105 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.cmdPrologue(AbstractQueryProtocol.java:2621) 106 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:311) 107 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:298) 108 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.setAutoCommit(AbstractQueryProtocol.java:1959) 109 at com.oceanbase.jdbc.OceanBaseConnection.setAutoCommit(OceanBaseConnection.java:969) 110 at com.alibaba.druid.pool.DruidConnectionHolder.reset(DruidConnectionHolder.java:312) 111 at com.alibaba.druid.pool.DruidDataSource.recycle(DruidDataSource.java:1949) 112 at com.alibaba.druid.pool.DruidPooledConnection.recycle(DruidPooledConnection.java:351) 113 at com.alibaba.druid.pool.DruidPooledConnection.close(DruidPooledConnection.java:288) 114 at com.oceanbase.oms.connector.jdbc.sink.AbstractDruidDataSourceBuilder.closeConnection(AbstractDruidDataSourceBuilder.java:46) 115 at com.oceanbase.oms.connector.jdbc.sink.Writer.closeConnection(Writer.java:753) 116 at com.oceanbase.oms.connector.jdbc.sink.Writer.resetConnection(Writer.java:734) 117 at com.oceanbase.oms.connector.jdbc.sink.Writer.handleRetry(Writer.java:711) 118 at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:513) 119 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDML(Writer.java:395) 120 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:287) 121 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 122 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 123 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 124 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 125 at java.lang.Thread.run(Thread.java:853) 126 [2024-04-01 10:05:01.883] [ERROR] [sinkTask-5] [recyle error] 127 java.sql.SQLNonTransientConnectionException: (conn=3221561137) Connection is closed 128 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.createException(ExceptionFactory.java:122) 129 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.create(ExceptionFactory.java:230) 130 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.cmdPrologue(AbstractQueryProtocol.java:2621) 131 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:311) 132 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:298) 133 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.setAutoCommit(AbstractQueryProtocol.java:1959) 134 at com.oceanbase.jdbc.OceanBaseConnection.setAutoCommit(OceanBaseConnection.java:969) 135 at com.alibaba.druid.pool.DruidConnectionHolder.reset(DruidConnectionHolder.java:312) 136 at com.alibaba.druid.pool.DruidDataSource.recycle(DruidDataSource.java:1949) 137 at com.alibaba.druid.pool.DruidPooledConnection.recycle(DruidPooledConnection.java:351) 138 at com.alibaba.druid.pool.DruidPooledConnection.close(DruidPooledConnection.java:288) 139 at com.oceanbase.oms.connector.jdbc.sink.AbstractDruidDataSourceBuilder.closeConnection(AbstractDruidDataSourceBuilder.java:46) 140 at com.oceanbase.oms.connector.jdbc.sink.Writer.closeConnection(Writer.java:753) 141 at com.oceanbase.oms.connector.jdbc.sink.Writer.resetConnection(Writer.java:734) 142 at com.oceanbase.oms.connector.jdbc.sink.Writer.handleRetry(Writer.java:711) 143 at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:513) 144 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDML(Writer.java:395) 145 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:287) 146 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 147 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 148 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 149 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 150 at java.lang.Thread.run(Thread.java:853) 151 [2024-04-01 10:05:53.282] [ERROR] [sinkTask-5] [recyle error] 152 java.sql.SQLNonTransientConnectionException: (conn=3221628774) Connection is closed 153 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.createException(ExceptionFactory.java:122) 154 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.create(ExceptionFactory.java:230) 155 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.cmdPrologue(AbstractQueryProtocol.java:2621) 156 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:311) 157 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:298) 158 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.setAutoCommit(AbstractQueryProtocol.java:1959) 159 at com.oceanbase.jdbc.OceanBaseConnection.setAutoCommit(OceanBaseConnection.java:969) 160 at com.alibaba.druid.pool.DruidConnectionHolder.reset(DruidConnectionHolder.java:312) 161 at com.alibaba.druid.pool.DruidDataSource.recycle(DruidDataSource.java:1949) 162 at com.alibaba.druid.pool.DruidPooledConnection.recycle(DruidPooledConnection.java:351) 163 at com.alibaba.druid.pool.DruidPooledConnection.close(DruidPooledConnection.java:288) 164 at com.oceanbase.oms.connector.jdbc.sink.AbstractDruidDataSourceBuilder.closeConnection(AbstractDruidDataSourceBuilder.java:46) 165 at com.oceanbase.oms.connector.jdbc.sink.Writer.closeConnection(Writer.java:753) 166 at com.oceanbase.oms.connector.jdbc.sink.Writer.resetConnection(Writer.java:734) 167 at com.oceanbase.oms.connector.jdbc.sink.Writer.handleRetry(Writer.java:711) 168 at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:513) 169 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDML(Writer.java:395) 170 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:287) 171 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 172 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 173 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 174 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 175 at java.lang.Thread.run(Thread.java:853) 176 [2024-04-01 10:06:45.395] [ERROR] [sinkTask-5] [recyle error] 177 java.sql.SQLNonTransientConnectionException: (conn=3221567606) Connection is closed 178 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.createException(ExceptionFactory.java:122) 179 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.create(ExceptionFactory.java:230) 180 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.cmdPrologue(AbstractQueryProtocol.java:2621) 181 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:311) 182 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:298) 183 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.setAutoCommit(AbstractQueryProtocol.java:1959) 184 at com.oceanbase.jdbc.OceanBaseConnection.setAutoCommit(OceanBaseConnection.java:969) 185 at com.alibaba.druid.pool.DruidConnectionHolder.reset(DruidConnectionHolder.java:312) 186 at com.alibaba.druid.pool.DruidDataSource.recycle(DruidDataSource.java:1949) 187 at com.alibaba.druid.pool.DruidPooledConnection.recycle(DruidPooledConnection.java:351) 188 at com.alibaba.druid.pool.DruidPooledConnection.close(DruidPooledConnection.java:288) 189 at com.oceanbase.oms.connector.jdbc.sink.AbstractDruidDataSourceBuilder.closeConnection(AbstractDruidDataSourceBuilder.java:46) 190 at com.oceanbase.oms.connector.jdbc.sink.Writer.closeConnection(Writer.java:753) 191 at com.oceanbase.oms.connector.jdbc.sink.Writer.resetConnection(Writer.java:734) 192 at com.oceanbase.oms.connector.jdbc.sink.Writer.handleRetry(Writer.java:711) 193 at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:513) 194 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDML(Writer.java:395) 195 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:287) 196 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 197 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 198 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 199 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 200 at java.lang.Thread.run(Thread.java:853) 201 [2024-04-01 10:07:37.941] [ERROR] [sinkTask-5] [recyle error] 202 java.sql.SQLNonTransientConnectionException: (conn=3221577024) Connection is closed 203 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.createException(ExceptionFactory.java:122) 204 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.create(ExceptionFactory.java:230) 205 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.cmdPrologue(AbstractQueryProtocol.java:2621) 206 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:311) 207 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:298) 208 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.setAutoCommit(AbstractQueryProtocol.java:1959) 209 at com.oceanbase.jdbc.OceanBaseConnection.setAutoCommit(OceanBaseConnection.java:969) 210 at com.alibaba.druid.pool.DruidConnectionHolder.reset(DruidConnectionHolder.java:312) 211 at com.alibaba.druid.pool.DruidDataSource.recycle(DruidDataSource.java:1949) 212 at com.alibaba.druid.pool.DruidPooledConnection.recycle(DruidPooledConnection.java:351) 213 at com.alibaba.druid.pool.DruidPooledConnection.close(DruidPooledConnection.java:288) 214 at com.oceanbase.oms.connector.jdbc.sink.AbstractDruidDataSourceBuilder.closeConnection(AbstractDruidDataSourceBuilder.java:46) 215 at com.oceanbase.oms.connector.jdbc.sink.Writer.closeConnection(Writer.java:753) 216 at com.oceanbase.oms.connector.jdbc.sink.Writer.resetConnection(Writer.java:734) 217 at com.oceanbase.oms.connector.jdbc.sink.Writer.handleRetry(Writer.java:711) 218 at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:513) 219 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDML(Writer.java:395) 220 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:287) 221 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 222 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 223 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 224 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 225 at java.lang.Thread.run(Thread.java:853) 226 [2024-04-01 10:08:29.818] [ERROR] [sinkTask-5] [recyle error] 227 java.sql.SQLNonTransientConnectionException: (conn=3221583137) Connection is closed 228 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.createException(ExceptionFactory.java:122) 229 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.create(ExceptionFactory.java:230) 230 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.cmdPrologue(AbstractQueryProtocol.java:2621) 231 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:311) 232 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:298) 233 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.setAutoCommit(AbstractQueryProtocol.java:1959) 234 at com.oceanbase.jdbc.OceanBaseConnection.setAutoCommit(OceanBaseConnection.java:969) 235 at com.alibaba.druid.pool.DruidConnectionHolder.reset(DruidConnectionHolder.java:312) 236 at com.alibaba.druid.pool.DruidDataSource.recycle(DruidDataSource.java:1949) 237 at com.alibaba.druid.pool.DruidPooledConnection.recycle(DruidPooledConnection.java:351) 238 at com.alibaba.druid.pool.DruidPooledConnection.close(DruidPooledConnection.java:288) 239 at com.oceanbase.oms.connector.jdbc.sink.AbstractDruidDataSourceBuilder.closeConnection(AbstractDruidDataSourceBuilder.java:46) 240 at com.oceanbase.oms.connector.jdbc.sink.Writer.closeConnection(Writer.java:753) 241 at com.oceanbase.oms.connector.jdbc.sink.Writer.resetConnection(Writer.java:734) 242 at com.oceanbase.oms.connector.jdbc.sink.Writer.handleRetry(Writer.java:711) 243 at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:513) 244 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDML(Writer.java:395) 245 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:287) 246 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 247 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 248 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 249 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 250 at java.lang.Thread.run(Thread.java:853) 251 [2024-04-01 10:09:21.820] [ERROR] [sinkTask-5] [recyle error] 252 java.sql.SQLNonTransientConnectionException: (conn=3221591433) Connection is closed 253 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.createException(ExceptionFactory.java:122) 254 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.create(ExceptionFactory.java:230) 255 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.cmdPrologue(AbstractQueryProtocol.java:2621) 256 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:311) 257 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:298) 258 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.setAutoCommit(AbstractQueryProtocol.java:1959) 259 at com.oceanbase.jdbc.OceanBaseConnection.setAutoCommit(OceanBaseConnection.java:969) 260 at com.alibaba.druid.pool.DruidConnectionHolder.reset(DruidConnectionHolder.java:312) 261 at com.alibaba.druid.pool.DruidDataSource.recycle(DruidDataSource.java:1949) 262 at com.alibaba.druid.pool.DruidPooledConnection.recycle(DruidPooledConnection.java:351) 263 at com.alibaba.druid.pool.DruidPooledConnection.close(DruidPooledConnection.java:288) 264 at com.oceanbase.oms.connector.jdbc.sink.AbstractDruidDataSourceBuilder.closeConnection(AbstractDruidDataSourceBuilder.java:46) 265 at com.oceanbase.oms.connector.jdbc.sink.Writer.closeConnection(Writer.java:753) 266 at com.oceanbase.oms.connector.jdbc.sink.Writer.resetConnection(Writer.java:734) 267 at com.oceanbase.oms.connector.jdbc.sink.Writer.handleRetry(Writer.java:711) 268 at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:513) 269 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDML(Writer.java:395) 270 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:287) 271 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 272 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 273 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 274 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 275 at java.lang.Thread.run(Thread.java:853) 276 [2024-04-01 10:10:13.836] [ERROR] [sinkTask-5] [recyle error] 277 java.sql.SQLNonTransientConnectionException: (conn=3221597188) Connection is closed 278 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.createException(ExceptionFactory.java:122) 279 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.create(ExceptionFactory.java:230) 280 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.cmdPrologue(AbstractQueryProtocol.java:2621) 281 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:311) 282 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:298) 283 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.setAutoCommit(AbstractQueryProtocol.java:1959) 284 at com.oceanbase.jdbc.OceanBaseConnection.setAutoCommit(OceanBaseConnection.java:969) 285 at com.alibaba.druid.pool.DruidConnectionHolder.reset(DruidConnectionHolder.java:312) 286 at com.alibaba.druid.pool.DruidDataSource.recycle(DruidDataSource.java:1949) 287 at com.alibaba.druid.pool.DruidPooledConnection.recycle(DruidPooledConnection.java:351) 288 at com.alibaba.druid.pool.DruidPooledConnection.close(DruidPooledConnection.java:288) 289 at com.oceanbase.oms.connector.jdbc.sink.AbstractDruidDataSourceBuilder.closeConnection(AbstractDruidDataSourceBuilder.java:46) 290 at com.oceanbase.oms.connector.jdbc.sink.Writer.closeConnection(Writer.java:753) 291 at com.oceanbase.oms.connector.jdbc.sink.Writer.resetConnection(Writer.java:734) 292 at com.oceanbase.oms.connector.jdbc.sink.Writer.handleRetry(Writer.java:711) 293 at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:513) 294 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDML(Writer.java:395) 295 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:287) 296 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 297 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 298 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 299 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 300 at java.lang.Thread.run(Thread.java:853) 301 [2024-04-01 10:11:05.967] [ERROR] [sinkTask-5] [recyle error] 302 java.sql.SQLNonTransientConnectionException: (conn=3221603922) Connection is closed 303 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.createException(ExceptionFactory.java:122) 304 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.create(ExceptionFactory.java:230) 305 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.cmdPrologue(AbstractQueryProtocol.java:2621) 306 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:311) 307 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:298) 308 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.setAutoCommit(AbstractQueryProtocol.java:1959) 309 at com.oceanbase.jdbc.OceanBaseConnection.setAutoCommit(OceanBaseConnection.java:969) 310 at com.alibaba.druid.pool.DruidConnectionHolder.reset(DruidConnectionHolder.java:312) 311 at com.alibaba.druid.pool.DruidDataSource.recycle(DruidDataSource.java:1949) 312 at com.alibaba.druid.pool.DruidPooledConnection.recycle(DruidPooledConnection.java:351) 313 at com.alibaba.druid.pool.DruidPooledConnection.close(DruidPooledConnection.java:288) 314 at com.oceanbase.oms.connector.jdbc.sink.AbstractDruidDataSourceBuilder.closeConnection(AbstractDruidDataSourceBuilder.java:46) 315 at com.oceanbase.oms.connector.jdbc.sink.Writer.closeConnection(Writer.java:753) 316 at com.oceanbase.oms.connector.jdbc.sink.Writer.resetConnection(Writer.java:734) 317 at com.oceanbase.oms.connector.jdbc.sink.Writer.handleRetry(Writer.java:711) 318 at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:513) 319 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDML(Writer.java:395) 320 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:287) 321 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 322 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 323 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 324 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 325 at java.lang.Thread.run(Thread.java:853) 326 [2024-04-01 10:11:58.355] [ERROR] [sinkTask-5] [recyle error] 327 java.sql.SQLNonTransientConnectionException: (conn=3221613846) Connection is closed 328 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.createException(ExceptionFactory.java:122) 329 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.create(ExceptionFactory.java:230) 330 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.cmdPrologue(AbstractQueryProtocol.java:2621) 331 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:311) 332 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:298) 333 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.setAutoCommit(AbstractQueryProtocol.java:1959) 334 at com.oceanbase.jdbc.OceanBaseConnection.setAutoCommit(OceanBaseConnection.java:969) 335 at com.alibaba.druid.pool.DruidConnectionHolder.reset(DruidConnectionHolder.java:312) 336 at com.alibaba.druid.pool.DruidDataSource.recycle(DruidDataSource.java:1949) 337 at com.alibaba.druid.pool.DruidPooledConnection.recycle(DruidPooledConnection.java:351) 338 at com.alibaba.druid.pool.DruidPooledConnection.close(DruidPooledConnection.java:288) 339 at com.oceanbase.oms.connector.jdbc.sink.AbstractDruidDataSourceBuilder.closeConnection(AbstractDruidDataSourceBuilder.java:46) 340 at com.oceanbase.oms.connector.jdbc.sink.Writer.closeConnection(Writer.java:753) 341 at com.oceanbase.oms.connector.jdbc.sink.Writer.resetConnection(Writer.java:734) 342 at com.oceanbase.oms.connector.jdbc.sink.Writer.handleRetry(Writer.java:711) 343 at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:513) 344 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDML(Writer.java:395) 345 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:287) 346 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 347 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 348 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 349 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 350 at java.lang.Thread.run(Thread.java:853) 351 [2024-04-01 10:12:50.120] [ERROR] [sinkTask-5] [recyle error] 352 java.sql.SQLNonTransientConnectionException: (conn=3221623303) Connection is closed 353 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.createException(ExceptionFactory.java:122) 354 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.create(ExceptionFactory.java:230) 355 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.cmdPrologue(AbstractQueryProtocol.java:2621) 356 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:311) 357 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:298) 358 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.setAutoCommit(AbstractQueryProtocol.java:1959) 359 at com.oceanbase.jdbc.OceanBaseConnection.setAutoCommit(OceanBaseConnection.java:969) 360 at com.alibaba.druid.pool.DruidConnectionHolder.reset(DruidConnectionHolder.java:312) 361 at com.alibaba.druid.pool.DruidDataSource.recycle(DruidDataSource.java:1949) 362 at com.alibaba.druid.pool.DruidPooledConnection.recycle(DruidPooledConnection.java:351) 363 at com.alibaba.druid.pool.DruidPooledConnection.close(DruidPooledConnection.java:288) 364 at com.oceanbase.oms.connector.jdbc.sink.AbstractDruidDataSourceBuilder.closeConnection(AbstractDruidDataSourceBuilder.java:46) 365 at com.oceanbase.oms.connector.jdbc.sink.Writer.closeConnection(Writer.java:753) 366 at com.oceanbase.oms.connector.jdbc.sink.Writer.resetConnection(Writer.java:734) 367 at com.oceanbase.oms.connector.jdbc.sink.Writer.handleRetry(Writer.java:711) 368 at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:513) 369 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDML(Writer.java:395) 370 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:287) 371 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 372 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 373 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 374 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 375 at java.lang.Thread.run(Thread.java:853) 376 [2024-04-01 10:13:43.161] [ERROR] [sinkTask-5] [recyle error] 377 java.sql.SQLNonTransientConnectionException: (conn=3221629878) Connection is closed 378 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.createException(ExceptionFactory.java:122) 379 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.create(ExceptionFactory.java:230) 380 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.cmdPrologue(AbstractQueryProtocol.java:2621) 381 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:311) 382 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:298) 383 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.setAutoCommit(AbstractQueryProtocol.java:1959) 384 at com.oceanbase.jdbc.OceanBaseConnection.setAutoCommit(OceanBaseConnection.java:969) 385 at com.alibaba.druid.pool.DruidConnectionHolder.reset(DruidConnectionHolder.java:312) 386 at com.alibaba.druid.pool.DruidDataSource.recycle(DruidDataSource.java:1949) 387 at com.alibaba.druid.pool.DruidPooledConnection.recycle(DruidPooledConnection.java:351) 388 at com.alibaba.druid.pool.DruidPooledConnection.close(DruidPooledConnection.java:288) 389 at com.oceanbase.oms.connector.jdbc.sink.AbstractDruidDataSourceBuilder.closeConnection(AbstractDruidDataSourceBuilder.java:46) 390 at com.oceanbase.oms.connector.jdbc.sink.Writer.closeConnection(Writer.java:753) 391 at com.oceanbase.oms.connector.jdbc.sink.Writer.resetConnection(Writer.java:734) 392 at com.oceanbase.oms.connector.jdbc.sink.Writer.handleRetry(Writer.java:711) 393 at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:513) 394 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDML(Writer.java:395) 395 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:287) 396 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 397 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 398 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 399 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 400 at java.lang.Thread.run(Thread.java:853) 401 [2024-04-01 10:14:36.092] [ERROR] [sinkTask-5] [recyle error] 402 java.sql.SQLNonTransientConnectionException: (conn=3221577023) Connection is closed 403 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.createException(ExceptionFactory.java:122) 404 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.create(ExceptionFactory.java:230) 405 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.cmdPrologue(AbstractQueryProtocol.java:2621) 406 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:311) 407 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:298) 408 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.setAutoCommit(AbstractQueryProtocol.java:1959) 409 at com.oceanbase.jdbc.OceanBaseConnection.setAutoCommit(OceanBaseConnection.java:969) 410 at com.alibaba.druid.pool.DruidConnectionHolder.reset(DruidConnectionHolder.java:312) 411 at com.alibaba.druid.pool.DruidDataSource.recycle(DruidDataSource.java:1949) 412 at com.alibaba.druid.pool.DruidPooledConnection.recycle(DruidPooledConnection.java:351) 413 at com.alibaba.druid.pool.DruidPooledConnection.close(DruidPooledConnection.java:288) 414 at com.oceanbase.oms.connector.jdbc.sink.AbstractDruidDataSourceBuilder.closeConnection(AbstractDruidDataSourceBuilder.java:46) 415 at com.oceanbase.oms.connector.jdbc.sink.Writer.closeConnection(Writer.java:753) 416 at com.oceanbase.oms.connector.jdbc.sink.Writer.resetConnection(Writer.java:734) 417 at com.oceanbase.oms.connector.jdbc.sink.Writer.handleRetry(Writer.java:711) 418 at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:513) 419 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDML(Writer.java:395) 420 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:287) 421 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 422 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 423 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 424 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 425 at java.lang.Thread.run(Thread.java:853) 426 [2024-04-01 10:15:28.593] [ERROR] [sinkTask-5] [recyle error] 427 java.sql.SQLNonTransientConnectionException: (conn=3221642709) Connection is closed 428 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.createException(ExceptionFactory.java:122) 429 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.create(ExceptionFactory.java:230) 430 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.cmdPrologue(AbstractQueryProtocol.java:2621) 431 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:311) 432 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:298) 433 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.setAutoCommit(AbstractQueryProtocol.java:1959) 434 at com.oceanbase.jdbc.OceanBaseConnection.setAutoCommit(OceanBaseConnection.java:969) 435 at com.alibaba.druid.pool.DruidConnectionHolder.reset(DruidConnectionHolder.java:312) 436 at com.alibaba.druid.pool.DruidDataSource.recycle(DruidDataSource.java:1949) 437 at com.alibaba.druid.pool.DruidPooledConnection.recycle(DruidPooledConnection.java:351) 438 at com.alibaba.druid.pool.DruidPooledConnection.close(DruidPooledConnection.java:288) 439 at com.oceanbase.oms.connector.jdbc.sink.AbstractDruidDataSourceBuilder.closeConnection(AbstractDruidDataSourceBuilder.java:46) 440 at com.oceanbase.oms.connector.jdbc.sink.Writer.closeConnection(Writer.java:753) 441 at com.oceanbase.oms.connector.jdbc.sink.Writer.resetConnection(Writer.java:734) 442 at com.oceanbase.oms.connector.jdbc.sink.Writer.handleRetry(Writer.java:711) 443 at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:513) 444 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDML(Writer.java:395) 445 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:287) 446 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 447 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 448 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 449 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 450 at java.lang.Thread.run(Thread.java:853) 451 [2024-04-01 10:16:20.501] [ERROR] [sinkTask-5] [recyle error] 452 java.sql.SQLNonTransientConnectionException: (conn=3221637407) Connection is closed 453 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.createException(ExceptionFactory.java:122) 454 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.create(ExceptionFactory.java:230) 455 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.cmdPrologue(AbstractQueryProtocol.java:2621) 456 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:311) 457 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:298) 458 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.setAutoCommit(AbstractQueryProtocol.java:1959) 459 at com.oceanbase.jdbc.OceanBaseConnection.setAutoCommit(OceanBaseConnection.java:969) 460 at com.alibaba.druid.pool.DruidConnectionHolder.reset(DruidConnectionHolder.java:312) 461 at com.alibaba.druid.pool.DruidDataSource.recycle(DruidDataSource.java:1949) 462 at com.alibaba.druid.pool.DruidPooledConnection.recycle(DruidPooledConnection.java:351) 463 at com.alibaba.druid.pool.DruidPooledConnection.close(DruidPooledConnection.java:288) 464 at com.oceanbase.oms.connector.jdbc.sink.AbstractDruidDataSourceBuilder.closeConnection(AbstractDruidDataSourceBuilder.java:46) 465 at com.oceanbase.oms.connector.jdbc.sink.Writer.closeConnection(Writer.java:753) 466 at com.oceanbase.oms.connector.jdbc.sink.Writer.resetConnection(Writer.java:734) 467 at com.oceanbase.oms.connector.jdbc.sink.Writer.handleRetry(Writer.java:711) 468 at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:513) 469 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDML(Writer.java:395) 470 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:287) 471 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 472 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 473 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 474 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 475 at java.lang.Thread.run(Thread.java:853) 476 [2024-04-01 10:17:11.628] [ERROR] [sinkTask-5] [recyle error] 477 java.sql.SQLNonTransientConnectionException: (conn=3221654551) Connection is closed 478 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.createException(ExceptionFactory.java:122) 479 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.create(ExceptionFactory.java:230) 480 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.cmdPrologue(AbstractQueryProtocol.java:2621) 481 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:311) 482 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:298) 483 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.setAutoCommit(AbstractQueryProtocol.java:1959) 484 at com.oceanbase.jdbc.OceanBaseConnection.setAutoCommit(OceanBaseConnection.java:969) 485 at com.alibaba.druid.pool.DruidConnectionHolder.reset(DruidConnectionHolder.java:312) 486 at com.alibaba.druid.pool.DruidDataSource.recycle(DruidDataSource.java:1949) 487 at com.alibaba.druid.pool.DruidPooledConnection.recycle(DruidPooledConnection.java:351) 488 at com.alibaba.druid.pool.DruidPooledConnection.close(DruidPooledConnection.java:288) 489 at com.oceanbase.oms.connector.jdbc.sink.AbstractDruidDataSourceBuilder.closeConnection(AbstractDruidDataSourceBuilder.java:46) 490 at com.oceanbase.oms.connector.jdbc.sink.Writer.closeConnection(Writer.java:753) 491 at com.oceanbase.oms.connector.jdbc.sink.Writer.resetConnection(Writer.java:734) 492 at com.oceanbase.oms.connector.jdbc.sink.Writer.handleRetry(Writer.java:711) 493 at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:513) 494 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDML(Writer.java:395) 495 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:287) 496 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 497 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 498 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 499 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 500 at java.lang.Thread.run(Thread.java:853) 501 [2024-04-01 10:18:03.459] [ERROR] [sinkTask-5] [recyle error] 502 java.sql.SQLNonTransientConnectionException: (conn=3221660079) Connection is closed 503 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.createException(ExceptionFactory.java:122) 504 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.create(ExceptionFactory.java:230) 505 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.cmdPrologue(AbstractQueryProtocol.java:2621) 506 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:311) 507 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:298) 508 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.setAutoCommit(AbstractQueryProtocol.java:1959) 509 at com.oceanbase.jdbc.OceanBaseConnection.setAutoCommit(OceanBaseConnection.java:969) 510 at com.alibaba.druid.pool.DruidConnectionHolder.reset(DruidConnectionHolder.java:312) 511 at com.alibaba.druid.pool.DruidDataSource.recycle(DruidDataSource.java:1949) 512 at com.alibaba.druid.pool.DruidPooledConnection.recycle(DruidPooledConnection.java:351) 513 at com.alibaba.druid.pool.DruidPooledConnection.close(DruidPooledConnection.java:288) 514 at com.oceanbase.oms.connector.jdbc.sink.AbstractDruidDataSourceBuilder.closeConnection(AbstractDruidDataSourceBuilder.java:46) 515 at com.oceanbase.oms.connector.jdbc.sink.Writer.closeConnection(Writer.java:753) 516 at com.oceanbase.oms.connector.jdbc.sink.Writer.resetConnection(Writer.java:734) 517 at com.oceanbase.oms.connector.jdbc.sink.Writer.handleRetry(Writer.java:711) 518 at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:513) 519 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDML(Writer.java:395) 520 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:287) 521 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 522 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 523 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 524 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 525 at java.lang.Thread.run(Thread.java:853) 526 [2024-04-01 10:18:56.385] [ERROR] [sinkTask-5] [recyle error] 527 java.sql.SQLNonTransientConnectionException: (conn=3221665467) Connection is closed 528 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.createException(ExceptionFactory.java:122) 529 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.create(ExceptionFactory.java:230) 530 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.cmdPrologue(AbstractQueryProtocol.java:2621) 531 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:311) 532 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:298) 533 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.setAutoCommit(AbstractQueryProtocol.java:1959) 534 at com.oceanbase.jdbc.OceanBaseConnection.setAutoCommit(OceanBaseConnection.java:969) 535 at com.alibaba.druid.pool.DruidConnectionHolder.reset(DruidConnectionHolder.java:312) 536 at com.alibaba.druid.pool.DruidDataSource.recycle(DruidDataSource.java:1949) 537 at com.alibaba.druid.pool.DruidPooledConnection.recycle(DruidPooledConnection.java:351) 538 at com.alibaba.druid.pool.DruidPooledConnection.close(DruidPooledConnection.java:288) 539 at com.oceanbase.oms.connector.jdbc.sink.AbstractDruidDataSourceBuilder.closeConnection(AbstractDruidDataSourceBuilder.java:46) 540 at com.oceanbase.oms.connector.jdbc.sink.Writer.closeConnection(Writer.java:753) 541 at com.oceanbase.oms.connector.jdbc.sink.Writer.resetConnection(Writer.java:734) 542 at com.oceanbase.oms.connector.jdbc.sink.Writer.handleRetry(Writer.java:711) 543 at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:513) 544 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDML(Writer.java:395) 545 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:287) 546 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 547 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 548 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 549 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 550 at java.lang.Thread.run(Thread.java:853) 551 [2024-04-01 10:19:48.765] [ERROR] [sinkTask-5] [recyle error] 552 java.sql.SQLNonTransientConnectionException: (conn=3221671239) Connection is closed 553 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.createException(ExceptionFactory.java:122) 554 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.create(ExceptionFactory.java:230) 555 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.cmdPrologue(AbstractQueryProtocol.java:2621) 556 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:311) 557 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:298) 558 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.setAutoCommit(AbstractQueryProtocol.java:1959) 559 at com.oceanbase.jdbc.OceanBaseConnection.setAutoCommit(OceanBaseConnection.java:969) 560 at com.alibaba.druid.pool.DruidConnectionHolder.reset(DruidConnectionHolder.java:312) 561 at com.alibaba.druid.pool.DruidDataSource.recycle(DruidDataSource.java:1949) 562 at com.alibaba.druid.pool.DruidPooledConnection.recycle(DruidPooledConnection.java:351) 563 at com.alibaba.druid.pool.DruidPooledConnection.close(DruidPooledConnection.java:288) 564 at com.oceanbase.oms.connector.jdbc.sink.AbstractDruidDataSourceBuilder.closeConnection(AbstractDruidDataSourceBuilder.java:46) 565 at com.oceanbase.oms.connector.jdbc.sink.Writer.closeConnection(Writer.java:753) 566 at com.oceanbase.oms.connector.jdbc.sink.Writer.resetConnection(Writer.java:734) 567 at com.oceanbase.oms.connector.jdbc.sink.Writer.handleRetry(Writer.java:711) 568 at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:513) 569 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDML(Writer.java:395) 570 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:287) 571 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 572 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 573 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 574 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 575 at java.lang.Thread.run(Thread.java:853) 576 [2024-04-01 10:20:40.540] [ERROR] [sinkTask-5] [recyle error] 577 java.sql.SQLNonTransientConnectionException: (conn=3221538416) Connection is closed 578 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.createException(ExceptionFactory.java:122) 579 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.create(ExceptionFactory.java:230) 580 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.cmdPrologue(AbstractQueryProtocol.java:2621) 581 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:311) 582 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:298) 583 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.setAutoCommit(AbstractQueryProtocol.java:1959) 584 at com.oceanbase.jdbc.OceanBaseConnection.setAutoCommit(OceanBaseConnection.java:969) 585 at com.alibaba.druid.pool.DruidConnectionHolder.reset(DruidConnectionHolder.java:312) 586 at com.alibaba.druid.pool.DruidDataSource.recycle(DruidDataSource.java:1949) 587 at com.alibaba.druid.pool.DruidPooledConnection.recycle(DruidPooledConnection.java:351) 588 at com.alibaba.druid.pool.DruidPooledConnection.close(DruidPooledConnection.java:288) 589 at com.oceanbase.oms.connector.jdbc.sink.AbstractDruidDataSourceBuilder.closeConnection(AbstractDruidDataSourceBuilder.java:46) 590 at com.oceanbase.oms.connector.jdbc.sink.Writer.closeConnection(Writer.java:753) 591 at com.oceanbase.oms.connector.jdbc.sink.Writer.resetConnection(Writer.java:734) 592 at com.oceanbase.oms.connector.jdbc.sink.Writer.handleRetry(Writer.java:711) 593 at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:513) 594 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDML(Writer.java:395) 595 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:287) 596 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 597 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 598 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 599 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 600 at java.lang.Thread.run(Thread.java:853) 601 [2024-04-01 10:21:32.805] [ERROR] [sinkTask-5] [recyle error] 602 java.sql.SQLNonTransientConnectionException: (conn=3221683938) Connection is closed 603 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.createException(ExceptionFactory.java:122) 604 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.create(ExceptionFactory.java:230) 605 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.cmdPrologue(AbstractQueryProtocol.java:2621) 606 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:311) 607 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:298) 608 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.setAutoCommit(AbstractQueryProtocol.java:1959) 609 at com.oceanbase.jdbc.OceanBaseConnection.setAutoCommit(OceanBaseConnection.java:969) 610 at com.alibaba.druid.pool.DruidConnectionHolder.reset(DruidConnectionHolder.java:312) 611 at com.alibaba.druid.pool.DruidDataSource.recycle(DruidDataSource.java:1949) 612 at com.alibaba.druid.pool.DruidPooledConnection.recycle(DruidPooledConnection.java:351) 613 at com.alibaba.druid.pool.DruidPooledConnection.close(DruidPooledConnection.java:288) 614 at com.oceanbase.oms.connector.jdbc.sink.AbstractDruidDataSourceBuilder.closeConnection(AbstractDruidDataSourceBuilder.java:46) 615 at com.oceanbase.oms.connector.jdbc.sink.Writer.closeConnection(Writer.java:753) 616 at com.oceanbase.oms.connector.jdbc.sink.Writer.resetConnection(Writer.java:734) 617 at com.oceanbase.oms.connector.jdbc.sink.Writer.handleRetry(Writer.java:711) 618 at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:513) 619 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDML(Writer.java:395) 620 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:287) 621 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 622 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 623 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 624 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 625 at java.lang.Thread.run(Thread.java:853) 626 [2024-04-01 10:22:24.449] [ERROR] [sinkTask-5] [recyle error] 627 java.sql.SQLNonTransientConnectionException: (conn=3221690692) Connection is closed 628 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.createException(ExceptionFactory.java:122) 629 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.create(ExceptionFactory.java:230) 630 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.cmdPrologue(AbstractQueryProtocol.java:2621) 631 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:311) 632 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:298) 633 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.setAutoCommit(AbstractQueryProtocol.java:1959) 634 at com.oceanbase.jdbc.OceanBaseConnection.setAutoCommit(OceanBaseConnection.java:969) 635 at com.alibaba.druid.pool.DruidConnectionHolder.reset(DruidConnectionHolder.java:312) 636 at com.alibaba.druid.pool.DruidDataSource.recycle(DruidDataSource.java:1949) 637 at com.alibaba.druid.pool.DruidPooledConnection.recycle(DruidPooledConnection.java:351) 638 at com.alibaba.druid.pool.DruidPooledConnection.close(DruidPooledConnection.java:288) 639 at com.oceanbase.oms.connector.jdbc.sink.AbstractDruidDataSourceBuilder.closeConnection(AbstractDruidDataSourceBuilder.java:46) 640 at com.oceanbase.oms.connector.jdbc.sink.Writer.closeConnection(Writer.java:753) 641 at com.oceanbase.oms.connector.jdbc.sink.Writer.resetConnection(Writer.java:734) 642 at com.oceanbase.oms.connector.jdbc.sink.Writer.handleRetry(Writer.java:711) 643 at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:513) 644 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDML(Writer.java:395) 645 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:287) 646 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 647 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 648 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 649 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 650 at java.lang.Thread.run(Thread.java:853) 651 [2024-04-01 10:23:16.323] [ERROR] [sinkTask-5] [recyle error] 652 java.sql.SQLNonTransientConnectionException: (conn=3221696097) Connection is closed 653 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.createException(ExceptionFactory.java:122) 654 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.create(ExceptionFactory.java:230) 655 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.cmdPrologue(AbstractQueryProtocol.java:2621) 656 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:311) 657 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:298) 658 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.setAutoCommit(AbstractQueryProtocol.java:1959) 659 at com.oceanbase.jdbc.OceanBaseConnection.setAutoCommit(OceanBaseConnection.java:969) 660 at com.alibaba.druid.pool.DruidConnectionHolder.reset(DruidConnectionHolder.java:312) 661 at com.alibaba.druid.pool.DruidDataSource.recycle(DruidDataSource.java:1949) 662 at com.alibaba.druid.pool.DruidPooledConnection.recycle(DruidPooledConnection.java:351) 663 at com.alibaba.druid.pool.DruidPooledConnection.close(DruidPooledConnection.java:288) 664 at com.oceanbase.oms.connector.jdbc.sink.AbstractDruidDataSourceBuilder.closeConnection(AbstractDruidDataSourceBuilder.java:46) 665 at com.oceanbase.oms.connector.jdbc.sink.Writer.closeConnection(Writer.java:753) 666 at com.oceanbase.oms.connector.jdbc.sink.Writer.resetConnection(Writer.java:734) 667 at com.oceanbase.oms.connector.jdbc.sink.Writer.handleRetry(Writer.java:711) 668 at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:513) 669 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDML(Writer.java:395) 670 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:287) 671 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 672 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 673 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 674 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 675 at java.lang.Thread.run(Thread.java:853) 676 [2024-04-01 10:24:08.171] [ERROR] [sinkTask-5] [recyle error] 677 java.sql.SQLNonTransientConnectionException: (conn=3221701766) Connection is closed 678 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.createException(ExceptionFactory.java:122) 679 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.create(ExceptionFactory.java:230) 680 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.cmdPrologue(AbstractQueryProtocol.java:2621) 681 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:311) 682 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:298) 683 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.setAutoCommit(AbstractQueryProtocol.java:1959) 684 at com.oceanbase.jdbc.OceanBaseConnection.setAutoCommit(OceanBaseConnection.java:969) 685 at com.alibaba.druid.pool.DruidConnectionHolder.reset(DruidConnectionHolder.java:312) 686 at com.alibaba.druid.pool.DruidDataSource.recycle(DruidDataSource.java:1949) 687 at com.alibaba.druid.pool.DruidPooledConnection.recycle(DruidPooledConnection.java:351) 688 at com.alibaba.druid.pool.DruidPooledConnection.close(DruidPooledConnection.java:288) 689 at com.oceanbase.oms.connector.jdbc.sink.AbstractDruidDataSourceBuilder.closeConnection(AbstractDruidDataSourceBuilder.java:46) 690 at com.oceanbase.oms.connector.jdbc.sink.Writer.closeConnection(Writer.java:753) 691 at com.oceanbase.oms.connector.jdbc.sink.Writer.resetConnection(Writer.java:734) 692 at com.oceanbase.oms.connector.jdbc.sink.Writer.handleRetry(Writer.java:711) 693 at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:513) 694 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDML(Writer.java:395) 695 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:287) 696 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 697 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 698 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 699 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 700 at java.lang.Thread.run(Thread.java:853) 701 [2024-04-01 10:25:00.063] [ERROR] [sinkTask-5] [recyle error] 702 java.sql.SQLNonTransientConnectionException: (conn=3221709904) Connection is closed 703 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.createException(ExceptionFactory.java:122) 704 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.create(ExceptionFactory.java:230) 705 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.cmdPrologue(AbstractQueryProtocol.java:2621) 706 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:311) 707 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:298) 708 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.setAutoCommit(AbstractQueryProtocol.java:1959) 709 at com.oceanbase.jdbc.OceanBaseConnection.setAutoCommit(OceanBaseConnection.java:969) 710 at com.alibaba.druid.pool.DruidConnectionHolder.reset(DruidConnectionHolder.java:312) 711 at com.alibaba.druid.pool.DruidDataSource.recycle(DruidDataSource.java:1949) 712 at com.alibaba.druid.pool.DruidPooledConnection.recycle(DruidPooledConnection.java:351) 713 at com.alibaba.druid.pool.DruidPooledConnection.close(DruidPooledConnection.java:288) 714 at com.oceanbase.oms.connector.jdbc.sink.AbstractDruidDataSourceBuilder.closeConnection(AbstractDruidDataSourceBuilder.java:46) 715 at com.oceanbase.oms.connector.jdbc.sink.Writer.closeConnection(Writer.java:753) 716 at com.oceanbase.oms.connector.jdbc.sink.Writer.resetConnection(Writer.java:734) 717 at com.oceanbase.oms.connector.jdbc.sink.Writer.handleRetry(Writer.java:711) 718 at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:513) 719 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDML(Writer.java:395) 720 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:287) 721 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 722 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 723 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 724 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 725 at java.lang.Thread.run(Thread.java:853) 726 [2024-04-01 10:25:52.825] [ERROR] [sinkTask-5] [recyle error] 727 java.sql.SQLNonTransientConnectionException: (conn=3221716591) Connection is closed 728 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.createException(ExceptionFactory.java:122) 729 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.create(ExceptionFactory.java:230) 730 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.cmdPrologue(AbstractQueryProtocol.java:2621) 731 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:311) 732 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:298) 733 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.setAutoCommit(AbstractQueryProtocol.java:1959) 734 at com.oceanbase.jdbc.OceanBaseConnection.setAutoCommit(OceanBaseConnection.java:969) 735 at com.alibaba.druid.pool.DruidConnectionHolder.reset(DruidConnectionHolder.java:312) 736 at com.alibaba.druid.pool.DruidDataSource.recycle(DruidDataSource.java:1949) 737 at com.alibaba.druid.pool.DruidPooledConnection.recycle(DruidPooledConnection.java:351) 738 at com.alibaba.druid.pool.DruidPooledConnection.close(DruidPooledConnection.java:288) 739 at com.oceanbase.oms.connector.jdbc.sink.AbstractDruidDataSourceBuilder.closeConnection(AbstractDruidDataSourceBuilder.java:46) 740 at com.oceanbase.oms.connector.jdbc.sink.Writer.closeConnection(Writer.java:753) 741 at com.oceanbase.oms.connector.jdbc.sink.Writer.resetConnection(Writer.java:734) 742 at com.oceanbase.oms.connector.jdbc.sink.Writer.handleRetry(Writer.java:711) 743 at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:513) 744 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDML(Writer.java:395) 745 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:287) 746 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 747 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 748 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 749 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 750 at java.lang.Thread.run(Thread.java:853) 751 [2024-04-01 10:26:43.885] [ERROR] [sinkTask-5] [recyle error] 752 java.sql.SQLNonTransientConnectionException: (conn=3221729092) Connection is closed 753 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.createException(ExceptionFactory.java:122) 754 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.create(ExceptionFactory.java:230) 755 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.cmdPrologue(AbstractQueryProtocol.java:2621) 756 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:311) 757 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:298) 758 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.setAutoCommit(AbstractQueryProtocol.java:1959) 759 at com.oceanbase.jdbc.OceanBaseConnection.setAutoCommit(OceanBaseConnection.java:969) 760 at com.alibaba.druid.pool.DruidConnectionHolder.reset(DruidConnectionHolder.java:312) 761 at com.alibaba.druid.pool.DruidDataSource.recycle(DruidDataSource.java:1949) 762 at com.alibaba.druid.pool.DruidPooledConnection.recycle(DruidPooledConnection.java:351) 763 at com.alibaba.druid.pool.DruidPooledConnection.close(DruidPooledConnection.java:288) 764 at com.oceanbase.oms.connector.jdbc.sink.AbstractDruidDataSourceBuilder.closeConnection(AbstractDruidDataSourceBuilder.java:46) 765 at com.oceanbase.oms.connector.jdbc.sink.Writer.closeConnection(Writer.java:753) 766 at com.oceanbase.oms.connector.jdbc.sink.Writer.resetConnection(Writer.java:734) 767 at com.oceanbase.oms.connector.jdbc.sink.Writer.handleRetry(Writer.java:711) 768 at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:513) 769 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDML(Writer.java:395) 770 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:287) 771 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 772 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 773 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 774 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 775 at java.lang.Thread.run(Thread.java:853) 776 [2024-04-01 10:27:35.136] [ERROR] [sinkTask-5] [recyle error] 777 java.sql.SQLNonTransientConnectionException: (conn=3221735021) Connection is closed 778 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.createException(ExceptionFactory.java:122) 779 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.create(ExceptionFactory.java:230) 780 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.cmdPrologue(AbstractQueryProtocol.java:2621) 781 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:311) 782 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:298) 783 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.setAutoCommit(AbstractQueryProtocol.java:1959) 784 at com.oceanbase.jdbc.OceanBaseConnection.setAutoCommit(OceanBaseConnection.java:969) 785 at com.alibaba.druid.pool.DruidConnectionHolder.reset(DruidConnectionHolder.java:312) 786 at com.alibaba.druid.pool.DruidDataSource.recycle(DruidDataSource.java:1949) 787 at com.alibaba.druid.pool.DruidPooledConnection.recycle(DruidPooledConnection.java:351) 788 at com.alibaba.druid.pool.DruidPooledConnection.close(DruidPooledConnection.java:288) 789 at com.oceanbase.oms.connector.jdbc.sink.AbstractDruidDataSourceBuilder.closeConnection(AbstractDruidDataSourceBuilder.java:46) 790 at com.oceanbase.oms.connector.jdbc.sink.Writer.closeConnection(Writer.java:753) 791 at com.oceanbase.oms.connector.jdbc.sink.Writer.resetConnection(Writer.java:734) 792 at com.oceanbase.oms.connector.jdbc.sink.Writer.handleRetry(Writer.java:711) 793 at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:513) 794 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDML(Writer.java:395) 795 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:287) 796 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 797 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 798 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 799 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 800 at java.lang.Thread.run(Thread.java:853) 801 [2024-04-01 10:28:27.795] [ERROR] [sinkTask-5] [recyle error] 802 java.sql.SQLNonTransientConnectionException: (conn=3221739403) Connection is closed 803 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.createException(ExceptionFactory.java:122) 804 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.create(ExceptionFactory.java:230) 805 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.cmdPrologue(AbstractQueryProtocol.java:2621) 806 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:311) 807 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:298) 808 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.setAutoCommit(AbstractQueryProtocol.java:1959) 809 at com.oceanbase.jdbc.OceanBaseConnection.setAutoCommit(OceanBaseConnection.java:969) 810 at com.alibaba.druid.pool.DruidConnectionHolder.reset(DruidConnectionHolder.java:312) 811 at com.alibaba.druid.pool.DruidDataSource.recycle(DruidDataSource.java:1949) 812 at com.alibaba.druid.pool.DruidPooledConnection.recycle(DruidPooledConnection.java:351) 813 at com.alibaba.druid.pool.DruidPooledConnection.close(DruidPooledConnection.java:288) 814 at com.oceanbase.oms.connector.jdbc.sink.AbstractDruidDataSourceBuilder.closeConnection(AbstractDruidDataSourceBuilder.java:46) 815 at com.oceanbase.oms.connector.jdbc.sink.Writer.closeConnection(Writer.java:753) 816 at com.oceanbase.oms.connector.jdbc.sink.Writer.resetConnection(Writer.java:734) 817 at com.oceanbase.oms.connector.jdbc.sink.Writer.handleRetry(Writer.java:711) 818 at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:513) 819 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDML(Writer.java:395) 820 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:287) 821 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 822 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 823 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 824 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 825 at java.lang.Thread.run(Thread.java:853) 826 [2024-04-01 10:29:20.147] [ERROR] [sinkTask-5] [recyle error] 827 java.sql.SQLNonTransientConnectionException: (conn=3221747112) Connection is closed 828 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.createException(ExceptionFactory.java:122) 829 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.create(ExceptionFactory.java:230) 830 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.cmdPrologue(AbstractQueryProtocol.java:2621) 831 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:311) 832 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:298) 833 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.setAutoCommit(AbstractQueryProtocol.java:1959) 834 at com.oceanbase.jdbc.OceanBaseConnection.setAutoCommit(OceanBaseConnection.java:969) 835 at com.alibaba.druid.pool.DruidConnectionHolder.reset(DruidConnectionHolder.java:312) 836 at com.alibaba.druid.pool.DruidDataSource.recycle(DruidDataSource.java:1949) 837 at com.alibaba.druid.pool.DruidPooledConnection.recycle(DruidPooledConnection.java:351) 838 at com.alibaba.druid.pool.DruidPooledConnection.close(DruidPooledConnection.java:288) 839 at com.oceanbase.oms.connector.jdbc.sink.AbstractDruidDataSourceBuilder.closeConnection(AbstractDruidDataSourceBuilder.java:46) 840 at com.oceanbase.oms.connector.jdbc.sink.Writer.closeConnection(Writer.java:753) 841 at com.oceanbase.oms.connector.jdbc.sink.Writer.resetConnection(Writer.java:734) 842 at com.oceanbase.oms.connector.jdbc.sink.Writer.handleRetry(Writer.java:711) 843 at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:513) 844 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDML(Writer.java:395) 845 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:287) 846 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 847 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 848 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 849 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 850 at java.lang.Thread.run(Thread.java:853) 851 [2024-04-01 10:30:11.586] [ERROR] [sinkTask-5] [recyle error] 852 java.sql.SQLNonTransientConnectionException: (conn=3221490479) Connection is closed 853 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.createException(ExceptionFactory.java:122) 854 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.create(ExceptionFactory.java:230) 855 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.cmdPrologue(AbstractQueryProtocol.java:2621) 856 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:311) 857 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:298) 858 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.setAutoCommit(AbstractQueryProtocol.java:1959) 859 at com.oceanbase.jdbc.OceanBaseConnection.setAutoCommit(OceanBaseConnection.java:969) 860 at com.alibaba.druid.pool.DruidConnectionHolder.reset(DruidConnectionHolder.java:312) 861 at com.alibaba.druid.pool.DruidDataSource.recycle(DruidDataSource.java:1949) 862 at com.alibaba.druid.pool.DruidPooledConnection.recycle(DruidPooledConnection.java:351) 863 at com.alibaba.druid.pool.DruidPooledConnection.close(DruidPooledConnection.java:288) 864 at com.oceanbase.oms.connector.jdbc.sink.AbstractDruidDataSourceBuilder.closeConnection(AbstractDruidDataSourceBuilder.java:46) 865 at com.oceanbase.oms.connector.jdbc.sink.Writer.closeConnection(Writer.java:753) 866 at com.oceanbase.oms.connector.jdbc.sink.Writer.resetConnection(Writer.java:734) 867 at com.oceanbase.oms.connector.jdbc.sink.Writer.handleRetry(Writer.java:711) 868 at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:513) 869 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDML(Writer.java:395) 870 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:287) 871 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 872 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 873 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 874 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 875 at java.lang.Thread.run(Thread.java:853) 876 [2024-04-01 10:31:03.433] [ERROR] [sinkTask-5] [recyle error] 877 java.sql.SQLNonTransientConnectionException: (conn=3221722088) Connection is closed 878 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.createException(ExceptionFactory.java:122) 879 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.create(ExceptionFactory.java:230) 880 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.cmdPrologue(AbstractQueryProtocol.java:2621) 881 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:311) 882 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:298) 883 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.setAutoCommit(AbstractQueryProtocol.java:1959) 884 at com.oceanbase.jdbc.OceanBaseConnection.setAutoCommit(OceanBaseConnection.java:969) 885 at com.alibaba.druid.pool.DruidConnectionHolder.reset(DruidConnectionHolder.java:312) 886 at com.alibaba.druid.pool.DruidDataSource.recycle(DruidDataSource.java:1949) 887 at com.alibaba.druid.pool.DruidPooledConnection.recycle(DruidPooledConnection.java:351) 888 at com.alibaba.druid.pool.DruidPooledConnection.close(DruidPooledConnection.java:288) 889 at com.oceanbase.oms.connector.jdbc.sink.AbstractDruidDataSourceBuilder.closeConnection(AbstractDruidDataSourceBuilder.java:46) 890 at com.oceanbase.oms.connector.jdbc.sink.Writer.closeConnection(Writer.java:753) 891 at com.oceanbase.oms.connector.jdbc.sink.Writer.resetConnection(Writer.java:734) 892 at com.oceanbase.oms.connector.jdbc.sink.Writer.handleRetry(Writer.java:711) 893 at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:513) 894 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDML(Writer.java:395) 895 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:287) 896 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 897 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 898 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 899 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 900 at java.lang.Thread.run(Thread.java:853) 901 [2024-04-01 10:31:55.448] [ERROR] [sinkTask-5] [recyle error] 902 java.sql.SQLNonTransientConnectionException: (conn=3221502629) Connection is closed 903 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.createException(ExceptionFactory.java:122) 904 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.create(ExceptionFactory.java:230) 905 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.cmdPrologue(AbstractQueryProtocol.java:2621) 906 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:311) 907 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:298) 908 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.setAutoCommit(AbstractQueryProtocol.java:1959) 909 at com.oceanbase.jdbc.OceanBaseConnection.setAutoCommit(OceanBaseConnection.java:969) 910 at com.alibaba.druid.pool.DruidConnectionHolder.reset(DruidConnectionHolder.java:312) 911 at com.alibaba.druid.pool.DruidDataSource.recycle(DruidDataSource.java:1949) 912 at com.alibaba.druid.pool.DruidPooledConnection.recycle(DruidPooledConnection.java:351) 913 at com.alibaba.druid.pool.DruidPooledConnection.close(DruidPooledConnection.java:288) 914 at com.oceanbase.oms.connector.jdbc.sink.AbstractDruidDataSourceBuilder.closeConnection(AbstractDruidDataSourceBuilder.java:46) 915 at com.oceanbase.oms.connector.jdbc.sink.Writer.closeConnection(Writer.java:753) 916 at com.oceanbase.oms.connector.jdbc.sink.Writer.resetConnection(Writer.java:734) 917 at com.oceanbase.oms.connector.jdbc.sink.Writer.handleRetry(Writer.java:711) 918 at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:513) 919 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDML(Writer.java:395) 920 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:287) 921 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 922 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 923 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 924 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 925 at java.lang.Thread.run(Thread.java:853) 926 [2024-04-01 10:32:46.926] [ERROR] [sinkTask-5] [recyle error] 927 java.sql.SQLNonTransientConnectionException: (conn=3221708977) Connection is closed 928 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.createException(ExceptionFactory.java:122) 929 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.create(ExceptionFactory.java:230) 930 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.cmdPrologue(AbstractQueryProtocol.java:2621) 931 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:311) 932 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery(AbstractQueryProtocol.java:298) 933 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.setAutoCommit(AbstractQueryProtocol.java:1959) 934 at com.oceanbase.jdbc.OceanBaseConnection.setAutoCommit(OceanBaseConnection.java:969) 935 at com.alibaba.druid.pool.DruidConnectionHolder.reset(DruidConnectionHolder.java:312) 936 at com.alibaba.druid.pool.DruidDataSource.recycle(DruidDataSource.java:1949) 937 at com.alibaba.druid.pool.DruidPooledConnection.recycle(DruidPooledConnection.java:351) 938 at com.alibaba.druid.pool.DruidPooledConnection.close(DruidPooledConnection.java:288) 939 at com.oceanbase.oms.connector.jdbc.sink.AbstractDruidDataSourceBuilder.closeConnection(AbstractDruidDataSourceBuilder.java:46) 940 at com.oceanbase.oms.connector.jdbc.sink.Writer.closeConnection(Writer.java:753) 941 at com.oceanbase.oms.connector.jdbc.sink.Writer.resetConnection(Writer.java:734) 942 at com.oceanbase.oms.connector.jdbc.sink.Writer.handleRetry(Writer.java:711) 943 at com.oceanbase.oms.connector.jdbc.sink.Writer.executeInRetry(Writer.java:513) 944 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushDML(Writer.java:395) 945 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:287) 946 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 947 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 948 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 949 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 950 at java.lang.Thread.run(Thread.java:853)