1 [2025-01-15 15:00:01.421] [INFO] [DRC-Client-Thread] [notify consume: 0.03389830508474576 ms] 2 [2025-01-15 15:01:01.429] [INFO] [DRC-Client-Thread] [notify consume: 0.13559322033898305 ms] 3 [2025-01-15 15:02:01.431] [INFO] [DRC-Client-Thread] [notify consume: 0.0847457627118644 ms] 4 [2025-01-15 15:03:01.439] [INFO] [DRC-Client-Thread] [notify consume: 0.05084745762711865 ms] 5 [2025-01-15 15:04:01.441] [INFO] [DRC-Client-Thread] [notify consume: 0.03389830508474576 ms] 6 [2025-01-15 15:05:01.455] [INFO] [DRC-Client-Thread] [notify consume: 0.03389830508474576 ms] 7 [2025-01-15 15:05:29.259] [WARN] [nioEventLoopGroup-4-1] [connection closed] 8 [2025-01-15 15:05:31.259] [WARN] [nioEventLoopGroup-4-1] [drcnet stopping...,drcnet recv buffer is set stopped, ignore data from netty] 9 [2025-01-15 15:05:31.266] [WARN] [nioEventLoopGroup-4-1] [connection is stopped] 10 [2025-01-15 15:05:31.266] [INFO] [DRC-Client-Thread] [Connect to http://10.186.17.23:17000/TIDB_np_6eppy4xurgu8_6eppzagtzun4-1-0 failed because read drcnet failed, server shutdown] 11 [2025-01-15 15:05:31.266] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.ServerProxy.getDrcNetResponse(ServerProxy.java:246)] 12 [2025-01-15 15:05:31.266] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.DRCClientImpl.run(DRCClientImpl.java:439)] 13 [2025-01-15 15:05:31.266] [INFO] [DRC-Client-Thread] [java.lang.Thread.run(Thread.java:853)] 14 [2025-01-15 15:05:31.266] [INFO] [DRC-Client-Thread] [After broken, retry cluster manager 1 out of 1] 15 [2025-01-15 15:05:31.266] [INFO] [DRC-Client-Thread] [Redirect to taskName: TIDB_np_6eppy4xurgu8_6eppzagtzun4-1-0] 16 [2025-01-15 15:05:41.295] [INFO] [DRC-Client-Thread] [Connect to http://10.186.17.23:17000/TIDB_np_6eppy4xurgu8_6eppzagtzun4-1-0 failed because Connection refused (Connection refused)] 17 [2025-01-15 15:05:41.296] [INFO] [DRC-Client-Thread] [java.net.PlainSocketImpl.socketConnect(Native Method)] 18 [2025-01-15 15:05:41.296] [INFO] [DRC-Client-Thread] [java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)] 19 [2025-01-15 15:05:41.296] [INFO] [DRC-Client-Thread] [java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)] 20 [2025-01-15 15:05:41.296] [INFO] [DRC-Client-Thread] [java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)] 21 [2025-01-15 15:05:41.296] [INFO] [DRC-Client-Thread] [java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)] 22 [2025-01-15 15:05:41.296] [INFO] [DRC-Client-Thread] [java.net.Socket.connect(Socket.java:656)] 23 [2025-01-15 15:05:41.296] [INFO] [DRC-Client-Thread] [org.apache.http.conn.scheme.PlainSocketFactory.connectSocket(PlainSocketFactory.java:121)] 24 [2025-01-15 15:05:41.296] [INFO] [DRC-Client-Thread] [org.apache.http.impl.conn.DefaultClientConnectionOperator.openConnection(DefaultClientConnectionOperator.java:180)] 25 [2025-01-15 15:05:41.296] [INFO] [DRC-Client-Thread] [org.apache.http.impl.conn.ManagedClientConnectionImpl.open(ManagedClientConnectionImpl.java:326)] 26 [2025-01-15 15:05:41.296] [INFO] [DRC-Client-Thread] [org.apache.http.impl.client.DefaultRequestDirector.tryConnect(DefaultRequestDirector.java:605)] 27 [2025-01-15 15:05:41.296] [INFO] [DRC-Client-Thread] [org.apache.http.impl.client.DefaultRequestDirector.execute(DefaultRequestDirector.java:440)] 28 [2025-01-15 15:05:41.296] [INFO] [DRC-Client-Thread] [org.apache.http.impl.client.AbstractHttpClient.doExecute(AbstractHttpClient.java:835)] 29 [2025-01-15 15:05:41.296] [INFO] [DRC-Client-Thread] [org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:83)] 30 [2025-01-15 15:05:41.296] [INFO] [DRC-Client-Thread] [org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:108)] 31 [2025-01-15 15:05:41.296] [INFO] [DRC-Client-Thread] [org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:56)] 32 [2025-01-15 15:05:41.296] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.HttpHandler.sendRequest(HttpHandler.java:157)] 33 [2025-01-15 15:05:41.296] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.HttpHandler.sendEncodedRequest(HttpHandler.java:163)] 34 [2025-01-15 15:05:41.296] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.ServerProxy.sendRequest(ServerProxy.java:150)] 35 [2025-01-15 15:05:41.296] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.ClusterManagers.connectStore(ClusterManagers.java:240)] 36 [2025-01-15 15:05:41.296] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.ClusterManagers.connectStore(ClusterManagers.java:139)] 37 [2025-01-15 15:05:41.296] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.ClusterManagers.findStore(ClusterManagers.java:105)] 38 [2025-01-15 15:05:41.296] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.DRCClientImpl.connectClusterManager(DRCClientImpl.java:380)] 39 [2025-01-15 15:05:41.296] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.DRCClientImpl.processRedirectMessage(DRCClientImpl.java:660)] 40 [2025-01-15 15:05:41.296] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.DRCClientImpl.run(DRCClientImpl.java:446)] 41 [2025-01-15 15:05:41.296] [INFO] [DRC-Client-Thread] [java.lang.Thread.run(Thread.java:853)] 42 [2025-01-15 15:05:41.296] [INFO] [DRC-Client-Thread] [After broken, retry cluster manager 2 out of 2] 43 [2025-01-15 15:05:41.296] [INFO] [DRC-Client-Thread] [Redirect to taskName: TIDB_np_6eppy4xurgu8_6eppzagtzun4-1-0] 44 [2025-01-15 15:05:51.320] [INFO] [DRC-Client-Thread] [Connect to http://10.186.17.23:17000/TIDB_np_6eppy4xurgu8_6eppzagtzun4-1-0 failed because CmBaseException(oldErrorCode=0, errMsg=Found no active stores under topic [TIDB_np_6eppy4xurgu8_6eppzagtzun4-1-0], reason=null, relativeDocs=null)] 45 [2025-01-15 15:05:51.320] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.ServerProxy.askStore(ServerProxy.java:487)] 46 [2025-01-15 15:05:51.320] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.ClusterManagers.findStore(ClusterManagers.java:101)] 47 [2025-01-15 15:05:51.320] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.DRCClientImpl.connectClusterManager(DRCClientImpl.java:380)] 48 [2025-01-15 15:05:51.320] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.DRCClientImpl.processRedirectMessage(DRCClientImpl.java:660)] 49 [2025-01-15 15:05:51.320] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.DRCClientImpl.run(DRCClientImpl.java:446)] 50 [2025-01-15 15:05:51.320] [INFO] [DRC-Client-Thread] [java.lang.Thread.run(Thread.java:853)] 51 [2025-01-15 15:05:51.320] [INFO] [DRC-Client-Thread] [After broken, retry cluster manager 3 out of 3] 52 [2025-01-15 15:05:51.320] [INFO] [DRC-Client-Thread] [Redirect to taskName: TIDB_np_6eppy4xurgu8_6eppzagtzun4-1-0] 53 [2025-01-15 15:06:01.345] [INFO] [DRC-Client-Thread] [Connect to http://10.186.17.23:17000/TIDB_np_6eppy4xurgu8_6eppzagtzun4-1-0 failed because CmBaseException(oldErrorCode=0, errMsg=Found no active stores under topic [TIDB_np_6eppy4xurgu8_6eppzagtzun4-1-0], reason=null, relativeDocs=null)] 54 [2025-01-15 15:06:01.345] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.ServerProxy.askStore(ServerProxy.java:487)] 55 [2025-01-15 15:06:01.345] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.ClusterManagers.findStore(ClusterManagers.java:101)] 56 [2025-01-15 15:06:01.345] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.DRCClientImpl.connectClusterManager(DRCClientImpl.java:380)] 57 [2025-01-15 15:06:01.345] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.DRCClientImpl.processRedirectMessage(DRCClientImpl.java:660)] 58 [2025-01-15 15:06:01.345] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.DRCClientImpl.run(DRCClientImpl.java:446)] 59 [2025-01-15 15:06:01.345] [INFO] [DRC-Client-Thread] [java.lang.Thread.run(Thread.java:853)] 60 [2025-01-15 15:06:01.345] [INFO] [DRC-Client-Thread] [After broken, retry cluster manager 4 out of 4] 61 [2025-01-15 15:06:01.345] [INFO] [DRC-Client-Thread] [Redirect to taskName: TIDB_np_6eppy4xurgu8_6eppzagtzun4-1-0] 62 [2025-01-15 15:06:11.367] [INFO] [DRC-Client-Thread] [Connect to http://10.186.17.23:17000/TIDB_np_6eppy4xurgu8_6eppzagtzun4-1-0 failed because CmBaseException(oldErrorCode=0, errMsg=Found no active stores under topic [TIDB_np_6eppy4xurgu8_6eppzagtzun4-1-0], reason=null, relativeDocs=null)] 63 [2025-01-15 15:06:11.367] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.ServerProxy.askStore(ServerProxy.java:487)] 64 [2025-01-15 15:06:11.367] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.ClusterManagers.findStore(ClusterManagers.java:101)] 65 [2025-01-15 15:06:11.367] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.DRCClientImpl.connectClusterManager(DRCClientImpl.java:380)] 66 [2025-01-15 15:06:11.367] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.DRCClientImpl.processRedirectMessage(DRCClientImpl.java:660)] 67 [2025-01-15 15:06:11.367] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.DRCClientImpl.run(DRCClientImpl.java:446)] 68 [2025-01-15 15:06:11.367] [INFO] [DRC-Client-Thread] [java.lang.Thread.run(Thread.java:853)] 69 [2025-01-15 15:06:11.367] [INFO] [DRC-Client-Thread] [After broken, retry cluster manager 5 out of 5] 70 [2025-01-15 15:06:11.367] [INFO] [DRC-Client-Thread] [Redirect to taskName: TIDB_np_6eppy4xurgu8_6eppzagtzun4-1-0] 71 [2025-01-15 15:06:21.390] [INFO] [DRC-Client-Thread] [Connect to http://10.186.17.23:17000/TIDB_np_6eppy4xurgu8_6eppzagtzun4-1-0 failed because CmBaseException(oldErrorCode=0, errMsg=Found no active stores under topic [TIDB_np_6eppy4xurgu8_6eppzagtzun4-1-0], reason=null, relativeDocs=null)] 72 [2025-01-15 15:06:21.390] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.ServerProxy.askStore(ServerProxy.java:487)] 73 [2025-01-15 15:06:21.390] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.ClusterManagers.findStore(ClusterManagers.java:101)] 74 [2025-01-15 15:06:21.390] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.DRCClientImpl.connectClusterManager(DRCClientImpl.java:380)] 75 [2025-01-15 15:06:21.390] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.DRCClientImpl.processRedirectMessage(DRCClientImpl.java:660)] 76 [2025-01-15 15:06:21.390] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.DRCClientImpl.run(DRCClientImpl.java:446)] 77 [2025-01-15 15:06:21.390] [INFO] [DRC-Client-Thread] [java.lang.Thread.run(Thread.java:853)] 78 [2025-01-15 15:06:21.390] [INFO] [DRC-Client-Thread] [After broken, retry cluster manager 6 out of 6] 79 [2025-01-15 15:06:21.390] [INFO] [DRC-Client-Thread] [Redirect to taskName: TIDB_np_6eppy4xurgu8_6eppzagtzun4-1-0] 80 [2025-01-15 15:06:31.412] [INFO] [DRC-Client-Thread] [Connect to http://10.186.17.23:17000/TIDB_np_6eppy4xurgu8_6eppzagtzun4-1-0 failed because CmBaseException(oldErrorCode=0, errMsg=Found no active stores under topic [TIDB_np_6eppy4xurgu8_6eppzagtzun4-1-0], reason=null, relativeDocs=null)] 81 [2025-01-15 15:06:31.412] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.ServerProxy.askStore(ServerProxy.java:487)] 82 [2025-01-15 15:06:31.412] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.ClusterManagers.findStore(ClusterManagers.java:101)] 83 [2025-01-15 15:06:31.412] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.DRCClientImpl.connectClusterManager(DRCClientImpl.java:380)] 84 [2025-01-15 15:06:31.412] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.DRCClientImpl.processRedirectMessage(DRCClientImpl.java:660)] 85 [2025-01-15 15:06:31.412] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.DRCClientImpl.run(DRCClientImpl.java:446)] 86 [2025-01-15 15:06:31.412] [INFO] [DRC-Client-Thread] [java.lang.Thread.run(Thread.java:853)] 87 [2025-01-15 15:06:31.412] [INFO] [DRC-Client-Thread] [After broken, retry cluster manager 7 out of 7] 88 [2025-01-15 15:06:31.412] [INFO] [DRC-Client-Thread] [Redirect to taskName: TIDB_np_6eppy4xurgu8_6eppzagtzun4-1-0] 89 [2025-01-15 15:06:41.435] [INFO] [DRC-Client-Thread] [Connect to http://10.186.17.23:17000/TIDB_np_6eppy4xurgu8_6eppzagtzun4-1-0 failed because CmBaseException(oldErrorCode=0, errMsg=Found no active stores under topic [TIDB_np_6eppy4xurgu8_6eppzagtzun4-1-0], reason=null, relativeDocs=null)] 90 [2025-01-15 15:06:41.435] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.ServerProxy.askStore(ServerProxy.java:487)] 91 [2025-01-15 15:06:41.435] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.ClusterManagers.findStore(ClusterManagers.java:101)] 92 [2025-01-15 15:06:41.435] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.DRCClientImpl.connectClusterManager(DRCClientImpl.java:380)] 93 [2025-01-15 15:06:41.435] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.DRCClientImpl.processRedirectMessage(DRCClientImpl.java:660)] 94 [2025-01-15 15:06:41.435] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.DRCClientImpl.run(DRCClientImpl.java:446)] 95 [2025-01-15 15:06:41.435] [INFO] [DRC-Client-Thread] [java.lang.Thread.run(Thread.java:853)] 96 [2025-01-15 15:06:41.435] [INFO] [DRC-Client-Thread] [After broken, retry cluster manager 8 out of 8] 97 [2025-01-15 15:06:41.435] [INFO] [DRC-Client-Thread] [Redirect to taskName: TIDB_np_6eppy4xurgu8_6eppzagtzun4-1-0] 98 [2025-01-15 15:06:51.456] [INFO] [DRC-Client-Thread] [Connect to http://10.186.17.23:17000/TIDB_np_6eppy4xurgu8_6eppzagtzun4-1-0 failed because CmBaseException(oldErrorCode=0, errMsg=Found no active stores under topic [TIDB_np_6eppy4xurgu8_6eppzagtzun4-1-0], reason=null, relativeDocs=null)] 99 [2025-01-15 15:06:51.457] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.ServerProxy.askStore(ServerProxy.java:487)] 100 [2025-01-15 15:06:51.457] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.ClusterManagers.findStore(ClusterManagers.java:101)] 101 [2025-01-15 15:06:51.457] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.DRCClientImpl.connectClusterManager(DRCClientImpl.java:380)] 102 [2025-01-15 15:06:51.457] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.DRCClientImpl.processRedirectMessage(DRCClientImpl.java:660)] 103 [2025-01-15 15:06:51.457] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.DRCClientImpl.run(DRCClientImpl.java:446)] 104 [2025-01-15 15:06:51.457] [INFO] [DRC-Client-Thread] [java.lang.Thread.run(Thread.java:853)] 105 [2025-01-15 15:06:51.457] [INFO] [DRC-Client-Thread] [After broken, retry cluster manager 9 out of 9] 106 [2025-01-15 15:06:51.457] [INFO] [DRC-Client-Thread] [Redirect to taskName: TIDB_np_6eppy4xurgu8_6eppzagtzun4-1-0] 107 [2025-01-15 15:07:01.490] [WARN] [DRC-Client-Thread] [drcnet client read timeout: 120] 108 [2025-01-15 15:07:01.492] [INFO] [nioEventLoopGroup-5-1] [get server version 2] 109 [2025-01-15 15:07:01.492] [INFO] [nioEventLoopGroup-5-1] [alloc id=1, server buf size: 1048576] 110 [2025-01-15 15:07:01.492] [WARN] [nioEventLoopGroup-5-1] [recv buf size is:1053696] 111 [2025-01-15 15:07:01.492] [WARN] [nioEventLoopGroup-5-1] [cache buf size is: 1048576] 112 [2025-01-15 15:07:01.492] [WARN] [nioEventLoopGroup-5-1] [cache buf size is: 1048576] 113 [2025-01-15 15:07:01.492] [WARN] [nioEventLoopGroup-5-1] [single conn start] 114 [2025-01-15 15:07:01.493] [INFO] [nioEventLoopGroup-5-1] [accept] 115 [2025-01-15 15:07:02.491] [INFO] [DRC-Client-Thread] [Connect to http://10.186.17.23:17000/TIDB_np_6eppy4xurgu8_6eppzagtzun4-1-0 successfully] 116 [2025-01-15 15:07:02.491] [INFO] [DRC-Client-Thread] [notify consume: 0.04 ms] 117 [2025-01-15 15:07:02.495] [INFO] [sinkTask-1] [batch replicate sql failed, use single statement replicate] 118 java.sql.BatchUpdateException: (conn=2635387) Duplicate entry '12414372' for key 'PRIMARY' 119 at com.oceanbase.jdbc.OceanBaseStatement.executeBatchExceptionEpilogue(OceanBaseStatement.java:448) 120 at com.oceanbase.jdbc.OceanBaseStatement.executeBatchExceptionEpilogue(OceanBaseStatement.java:451) 121 at com.oceanbase.jdbc.JDBC4PreparedStatement.executeBatch(JDBC4PreparedStatement.java:341) 122 at com.alibaba.druid.pool.DruidPooledPreparedStatement.executeBatch(DruidPooledPreparedStatement.java:565) 123 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:263) 124 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 125 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 126 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 127 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 128 at java.lang.Thread.run(Thread.java:853) 129 Caused by: java.sql.SQLIntegrityConstraintViolationException: (conn=2635387) Duplicate entry '12414372' for key 'PRIMARY' 130 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.createException(ExceptionFactory.java:118) 131 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.create(ExceptionFactory.java:202) 132 at com.oceanbase.jdbc.OceanBaseStatement.executeBatchExceptionEpilogue(OceanBaseStatement.java:444) 133 ... 9 common frames omitted 134 Caused by: com.oceanbase.jdbc.internal.util.exceptions.OceanBaseSqlException: Duplicate entry '12414372' for key 'PRIMARY' 135 at com.oceanbase.jdbc.internal.util.exceptions.OceanBaseSqlException.of(OceanBaseSqlException.java:79) 136 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeBatchRewrite(AbstractQueryProtocol.java:1252) 137 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeBatchClient(AbstractQueryProtocol.java:687) 138 at com.oceanbase.jdbc.JDBC4PreparedStatement.executeInternalBatch(JDBC4PreparedStatement.java:456) 139 at com.oceanbase.jdbc.JDBC4PreparedStatement.executeBatch(JDBC4PreparedStatement.java:326) 140 ... 7 common frames omitted 141 Caused by: java.sql.SQLException: Duplicate entry '12414372' for key 'PRIMARY' 142 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.readErrorPacket(AbstractQueryProtocol.java:2364) 143 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.readPacket(AbstractQueryProtocol.java:2227) 144 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.getResult(AbstractQueryProtocol.java:2115) 145 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeBatchRewrite(AbstractQueryProtocol.java:1244) 146 ... 10 common frames omitted 147 [2025-01-15 15:07:02.498] [WARN] [sinkTask-1] [Ignore current oms record [meta[odb58_tidb_realtime_slow-tidb_realtime_cluster_slow_queries,1736923699,INSERT,1736923699]post[Struct{id(INT32)=12414372,igid(VAR_CHAR_STRING)=29700-1,zabbix_unix_time(INT32)=1736923200,begin_time(DATETIME)=2025-01-15 14:40:00,end_time(DATETIME)=2025-01-15 14:45:00,slow_queries(INT32)=2170,create_time(DATETIME)=2025-01-15 14:48:19,day_time(DATE)=2025-01-15}]] for exception [(conn=2635387) Duplicate entry '12414372' for key 'PRIMARY']] 148 [2025-01-15 15:07:09.807] [INFO] [sinkTask-6] [batch replicate sql failed, use single statement replicate] 149 java.sql.BatchUpdateException: (conn=3400977) Duplicate entry '12414372' for key 'PRIMARY' 150 at com.oceanbase.jdbc.OceanBaseStatement.executeBatchExceptionEpilogue(OceanBaseStatement.java:448) 151 at com.oceanbase.jdbc.OceanBaseStatement.executeBatchExceptionEpilogue(OceanBaseStatement.java:451) 152 at com.oceanbase.jdbc.JDBC4PreparedStatement.executeBatch(JDBC4PreparedStatement.java:341) 153 at com.alibaba.druid.pool.DruidPooledPreparedStatement.executeBatch(DruidPooledPreparedStatement.java:565) 154 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:263) 155 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:193) 156 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 157 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 158 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 159 at java.lang.Thread.run(Thread.java:853) 160 Caused by: java.sql.SQLIntegrityConstraintViolationException: (conn=3400977) Duplicate entry '12414372' for key 'PRIMARY' 161 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.createException(ExceptionFactory.java:118) 162 at com.oceanbase.jdbc.internal.util.exceptions.ExceptionFactory.create(ExceptionFactory.java:202) 163 at com.oceanbase.jdbc.OceanBaseStatement.executeBatchExceptionEpilogue(OceanBaseStatement.java:444) 164 ... 9 common frames omitted 165 Caused by: com.oceanbase.jdbc.internal.util.exceptions.OceanBaseSqlException: Duplicate entry '12414372' for key 'PRIMARY' 166 at com.oceanbase.jdbc.internal.util.exceptions.OceanBaseSqlException.of(OceanBaseSqlException.java:79) 167 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeBatchRewrite(AbstractQueryProtocol.java:1252) 168 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeBatchClient(AbstractQueryProtocol.java:687) 169 at com.oceanbase.jdbc.JDBC4PreparedStatement.executeInternalBatch(JDBC4PreparedStatement.java:456) 170 at com.oceanbase.jdbc.JDBC4PreparedStatement.executeBatch(JDBC4PreparedStatement.java:326) 171 ... 7 common frames omitted 172 Caused by: java.sql.SQLException: Duplicate entry '12414372' for key 'PRIMARY' 173 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.readErrorPacket(AbstractQueryProtocol.java:2364) 174 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.readPacket(AbstractQueryProtocol.java:2227) 175 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.getResult(AbstractQueryProtocol.java:2115) 176 at com.oceanbase.jdbc.internal.protocol.AbstractQueryProtocol.executeBatchRewrite(AbstractQueryProtocol.java:1244) 177 ... 10 common frames omitted 178 [2025-01-15 15:07:09.810] [WARN] [sinkTask-6] [Ignore current oms record [meta[odb58_tidb_realtime_slow-tidb_realtime_cluster_slow_queries,1736923699,INSERT,1736923699]post[Struct{id(INT32)=12414372,igid(VAR_CHAR_STRING)=29700-1,zabbix_unix_time(INT32)=1736923200,begin_time(DATETIME)=2025-01-15 14:40:00,end_time(DATETIME)=2025-01-15 14:45:00,slow_queries(INT32)=2170,create_time(DATETIME)=2025-01-15 14:48:19,day_time(DATE)=2025-01-15}]] for exception [(conn=3400977) Duplicate entry '12414372' for key 'PRIMARY']] 179 [2025-01-15 15:08:02.812] [INFO] [DRC-Client-Thread] [notify consume: 0.005929919137466307 ms] 180 [2025-01-15 15:09:02.881] [INFO] [DRC-Client-Thread] [notify consume: 0.07865168539325842 ms] 181 [2025-01-15 15:10:02.957] [INFO] [DRC-Client-Thread] [notify consume: 0.017241379310344827 ms] 182 [2025-01-15 15:11:03.011] [INFO] [DRC-Client-Thread] [notify consume: 0.05714285714285714 ms] 183 [2025-01-15 15:12:03.091] [INFO] [DRC-Client-Thread] [notify consume: 0.04225352112676056 ms] 184 [2025-01-15 15:13:03.168] [INFO] [DRC-Client-Thread] [notify consume: 0.0625 ms] 185 [2025-01-15 15:14:03.230] [INFO] [DRC-Client-Thread] [notify consume: 0.04201680672268908 ms] 186 [2025-01-15 15:15:03.294] [INFO] [DRC-Client-Thread] [notify consume: 0.02586206896551724 ms] 187 [2025-01-15 15:16:03.351] [INFO] [DRC-Client-Thread] [notify consume: 0.030612244897959183 ms] 188 [2025-01-15 15:17:03.447] [INFO] [DRC-Client-Thread] [notify consume: 0.05194805194805195 ms] 189 [2025-01-15 15:18:03.516] [INFO] [DRC-Client-Thread] [notify consume: 0.056338028169014086 ms] 190 [2025-01-15 15:19:03.574] [INFO] [DRC-Client-Thread] [notify consume: 0.0234375 ms] 191 [2025-01-15 15:20:03.638] [INFO] [DRC-Client-Thread] [notify consume: 0.034482758620689655 ms] 192 [2025-01-15 15:21:03.704] [INFO] [DRC-Client-Thread] [notify consume: 0.04081632653061224 ms] 193 [2025-01-15 15:22:03.770] [INFO] [DRC-Client-Thread] [notify consume: 0.025974025974025976 ms] 194 [2025-01-15 15:23:03.990] [INFO] [DRC-Client-Thread] [notify consume: 0.06756756756756757 ms] 195 [2025-01-15 15:24:04.911] [INFO] [DRC-Client-Thread] [notify consume: 0.032520325203252036 ms] 196 [2025-01-15 15:25:04.965] [INFO] [DRC-Client-Thread] [notify consume: 0.025210084033613446 ms] 197 [2025-01-15 15:26:05.084] [INFO] [DRC-Client-Thread] [notify consume: 0.057971014492753624 ms] 198 [2025-01-15 15:27:05.187] [INFO] [DRC-Client-Thread] [notify consume: 0.04807692307692308 ms] 199 [2025-01-15 15:28:05.788] [INFO] [DRC-Client-Thread] [notify consume: 0.04225352112676056 ms] 200 [2025-01-15 15:29:06.276] [INFO] [DRC-Client-Thread] [notify consume: 0.03508771929824561 ms] 201 [2025-01-15 15:30:06.350] [INFO] [DRC-Client-Thread] [notify consume: 0.029850746268656716 ms] 202 [2025-01-15 15:31:06.415] [INFO] [DRC-Client-Thread] [notify consume: 0.01818181818181818 ms] 203 [2025-01-15 15:32:06.493] [INFO] [DRC-Client-Thread] [notify consume: 0.039603960396039604 ms] 204 [2025-01-15 15:33:06.568] [INFO] [DRC-Client-Thread] [notify consume: 0.04225352112676056 ms] 205 [2025-01-15 15:34:06.643] [INFO] [DRC-Client-Thread] [notify consume: 0.028037383177570093 ms] 206 [2025-01-15 15:35:06.790] [INFO] [DRC-Client-Thread] [notify consume: 0.04950495049504951 ms] 207 [2025-01-15 15:36:07.775] [INFO] [DRC-Client-Thread] [notify consume: 0.05128205128205128 ms] 208 [2025-01-15 15:37:07.827] [INFO] [DRC-Client-Thread] [notify consume: 0.04081632653061224 ms] 209 [2025-01-15 15:38:07.977] [INFO] [DRC-Client-Thread] [notify consume: 0.04054054054054054 ms] 210 [2025-01-15 15:39:08.042] [INFO] [DRC-Client-Thread] [notify consume: 0.06944444444444445 ms] 211 [2025-01-15 15:40:08.098] [INFO] [DRC-Client-Thread] [notify consume: 0.03278688524590164 ms] 212 [2025-01-15 15:41:08.181] [INFO] [DRC-Client-Thread] [notify consume: 0.02459016393442623 ms] 213 [2025-01-15 15:42:08.248] [INFO] [DRC-Client-Thread] [notify consume: 0.028846153846153848 ms] 214 [2025-01-15 15:43:08.291] [INFO] [DRC-Client-Thread] [notify consume: 0.05405405405405406 ms] 215 [2025-01-15 15:44:08.350] [INFO] [DRC-Client-Thread] [notify consume: 0.028169014084507043 ms] 216 [2025-01-15 15:45:08.363] [INFO] [DRC-Client-Thread] [notify consume: 0.06779661016949153 ms] 217 [2025-01-15 15:46:08.368] [INFO] [DRC-Client-Thread] [notify consume: 0.01694915254237288 ms] 218 [2025-01-15 15:47:08.373] [INFO] [DRC-Client-Thread] [notify consume: 0.05084745762711865 ms] 219 [2025-01-15 15:48:08.378] [INFO] [DRC-Client-Thread] [notify consume: 0.03389830508474576 ms] 220 [2025-01-15 15:49:08.384] [INFO] [DRC-Client-Thread] [notify consume: 0.0 ms] 221 [2025-01-15 15:50:08.388] [INFO] [DRC-Client-Thread] [notify consume: 0.05084745762711865 ms] 222 [2025-01-15 15:51:08.396] [INFO] [DRC-Client-Thread] [notify consume: 0.05084745762711865 ms] 223 [2025-01-15 15:52:08.398] [INFO] [DRC-Client-Thread] [notify consume: 0.0847457627118644 ms] 224 [2025-01-15 15:53:08.402] [INFO] [DRC-Client-Thread] [notify consume: 0.03389830508474576 ms] 225 [2025-01-15 15:54:08.410] [INFO] [DRC-Client-Thread] [notify consume: 0.03389830508474576 ms] 226 [2025-01-15 15:55:08.418] [INFO] [DRC-Client-Thread] [notify consume: 0.01694915254237288 ms] 227 [2025-01-15 15:56:08.421] [INFO] [DRC-Client-Thread] [notify consume: 0.05084745762711865 ms] 228 [2025-01-15 15:57:08.430] [INFO] [DRC-Client-Thread] [notify consume: 0.03389830508474576 ms] 229 [2025-01-15 15:58:08.434] [INFO] [DRC-Client-Thread] [notify consume: 0.06779661016949153 ms] 230 [2025-01-15 15:59:08.441] [INFO] [DRC-Client-Thread] [notify consume: 0.01694915254237288 ms]