1 [2025-01-17 00:24:55.235] [ERROR] [sinkTask-2] [recyle error] 2 java.sql.SQLNonTransientConnectionException: (conn=1320066) 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 [2025-01-17 00:24:55.249] [ERROR] [sinkTask-0] [recyle error] 27 java.sql.SQLNonTransientConnectionException: (conn=1332580) 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 [2025-01-17 00:24:55.360] [ERROR] [sinkTask-1] [recyle error] 52 java.sql.SQLNonTransientConnectionException: (conn=1330248) 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 [2025-01-17 00:24:55.474] [ERROR] [sinkTask-3] [recyle error] 77 java.sql.SQLNonTransientConnectionException: (conn=1327561) 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 [2025-01-17 00:25:31.090] [ERROR] [DRC-Client-Thread] [Receive measure exception.] 102 java.lang.IllegalArgumentException: Requested permits must be positive 103 at com.oceanbase.oms.connector.common.guava.OmsRateLimiter.checkPermits(OmsRateLimiter.java:108) 104 at com.oceanbase.oms.connector.common.guava.OmsRateLimiter.acquire(OmsRateLimiter.java:70) 105 at com.oceanbase.oms.connector.common.throttle.speed.IOPSThrottle.inThrottle(IOPSThrottle.java:17) 106 at com.oceanbase.oms.connector.common.ThrottleCenter.inThrottle(ThrottleCenter.java:37) 107 at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager$ControlOfferInterfaceWarp.offer(SourceTaskManager.java:130) 108 at com.oceanbase.oms.connector.batch.CommonTransactionAssembler$TransactionAssemblerInner.offer(CommonTransactionAssembler.java:329) 109 at com.oceanbase.oms.connector.message.ControlMessageExecutor.execute(ControlMessageExecutor.java:39) 110 at com.oceanbase.oms.connector.batch.CommonTransactionAssembler$TransactionAssemblerInner.putTransaction(CommonTransactionAssembler.java:320) 111 at com.oceanbase.oms.connector.batch.CommonTransactionAssembler$XATransactionAssemblerInner.generateTransaction(CommonTransactionAssembler.java:406) 112 at com.oceanbase.oms.connector.batch.CommonTransactionAssembler.notify(CommonTransactionAssembler.java:109) 113 at com.oceanbase.oms.connector.source.store.TransactionAssembler.notify(TransactionAssembler.java:97) 114 at com.oceanbase.oms.store.client.impl.DRCClientImpl.notifyDataMessage(DRCClientImpl.java:568) 115 at com.oceanbase.oms.store.client.impl.DRCClientImpl.notifyDataMessage(DRCClientImpl.java:534) 116 at com.oceanbase.oms.store.client.impl.DRCClientImpl.run(DRCClientImpl.java:451) 117 at java.lang.Thread.run(Thread.java:853) 118 [2025-01-17 00:25:31.092] [ERROR] [DRC-Client-Thread] [notifyStopped:] 119 com.oceanbase.oms.connector.common.exception.NotifyException: java.lang.IllegalArgumentException: Requested permits must be positive 120 at com.oceanbase.oms.connector.common.exception.AbstractNotifyExceptionHandler.doBuildNotifyException(AbstractNotifyExceptionHandler.java:48) 121 at com.oceanbase.oms.connector.common.exception.AbstractNotifyExceptionHandler.buildNotifyException(AbstractNotifyExceptionHandler.java:39) 122 at com.oceanbase.oms.connector.source.store.TransactionAssembler.handleException(TransactionAssembler.java:108) 123 at com.oceanbase.oms.store.client.impl.DRCClientImpl.notifyDataMessage(DRCClientImpl.java:557) 124 at com.oceanbase.oms.store.client.impl.DRCClientImpl.run(DRCClientImpl.java:451) 125 at java.lang.Thread.run(Thread.java:853) 126 Caused by: java.lang.IllegalArgumentException: Requested permits must be positive 127 at com.oceanbase.oms.connector.common.guava.OmsRateLimiter.checkPermits(OmsRateLimiter.java:108) 128 at com.oceanbase.oms.connector.common.guava.OmsRateLimiter.acquire(OmsRateLimiter.java:70) 129 at com.oceanbase.oms.connector.common.throttle.speed.IOPSThrottle.inThrottle(IOPSThrottle.java:17) 130 at com.oceanbase.oms.connector.common.ThrottleCenter.inThrottle(ThrottleCenter.java:37) 131 at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager$ControlOfferInterfaceWarp.offer(SourceTaskManager.java:130) 132 at com.oceanbase.oms.connector.batch.CommonTransactionAssembler$TransactionAssemblerInner.offer(CommonTransactionAssembler.java:329) 133 at com.oceanbase.oms.connector.message.ControlMessageExecutor.execute(ControlMessageExecutor.java:39) 134 at com.oceanbase.oms.connector.batch.CommonTransactionAssembler$TransactionAssemblerInner.putTransaction(CommonTransactionAssembler.java:320) 135 at com.oceanbase.oms.connector.batch.CommonTransactionAssembler$XATransactionAssemblerInner.generateTransaction(CommonTransactionAssembler.java:406) 136 at com.oceanbase.oms.connector.batch.CommonTransactionAssembler.notify(CommonTransactionAssembler.java:109) 137 at com.oceanbase.oms.connector.source.store.TransactionAssembler.notify(TransactionAssembler.java:97) 138 at com.oceanbase.oms.store.client.impl.DRCClientImpl.notifyDataMessage(DRCClientImpl.java:568) 139 at com.oceanbase.oms.store.client.impl.DRCClientImpl.notifyDataMessage(DRCClientImpl.java:534) 140 ... 2 common frames omitted 141 [2025-01-17 00:25:32.396] [ERROR] [DRC-Client-Thread] [close connection interrupted: java.lang.InterruptedException: AbstractChannel$CloseFuture@5e418ee1(incomplete)]