1 java.sql.BatchUpdateException: Duplicate entry '5226389096' for key 'PRIMARY' 2 at sun.reflect.GeneratedConstructorAccessor35.newInstance(Unknown Source) 3 at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) 4 at java.lang.reflect.Constructor.newInstance(Constructor.java:423) 5 at com.mysql.jdbc.Util.handleNewInstance(Util.java:425) 6 at com.mysql.jdbc.Util.getInstance(Util.java:408) 7 at com.mysql.jdbc.SQLError.createBatchUpdateException(SQLError.java:1163) 8 at com.mysql.jdbc.PreparedStatement.executeBatchedInserts(PreparedStatement.java:1632) 9 at com.mysql.jdbc.PreparedStatement.executeBatchInternal(PreparedStatement.java:1298) 10 at com.mysql.jdbc.StatementImpl.executeBatch(StatementImpl.java:970) 11 at com.alibaba.druid.pool.DruidPooledPreparedStatement.executeBatch(DruidPooledPreparedStatement.java:565) 12 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:265) 13 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:195) 14 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 15 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 16 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 17 at java.lang.Thread.run(Thread.java:853) 18 Caused by: com.mysql.jdbc.exceptions.jdbc4.MySQLIntegrityConstraintViolationException: Duplicate entry '5226389096' for key 'PRIMARY' 19 at sun.reflect.GeneratedConstructorAccessor27.newInstance(Unknown Source) 20 at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) 21 at java.lang.reflect.Constructor.newInstance(Constructor.java:423) 22 at com.mysql.jdbc.Util.handleNewInstance(Util.java:425) 23 at com.mysql.jdbc.Util.getInstance(Util.java:408) 24 at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:936) 25 at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3978) 26 at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3914) 27 at com.mysql.jdbc.MysqlIO.sendCommand(MysqlIO.java:2530) 28 at com.mysql.jdbc.MysqlIO.sqlQueryDirect(MysqlIO.java:2683) 29 at com.mysql.jdbc.ConnectionImpl.execSQL(ConnectionImpl.java:2495) 30 at com.mysql.jdbc.PreparedStatement.executeInternal(PreparedStatement.java:1903) 31 at com.mysql.jdbc.PreparedStatement.executeUpdateInternal(PreparedStatement.java:2124) 32 at com.mysql.jdbc.PreparedStatement.executeUpdateInternal(PreparedStatement.java:2058) 33 at com.mysql.jdbc.PreparedStatement.executeLargeUpdate(PreparedStatement.java:5158) 34 at com.mysql.jdbc.PreparedStatement.executeBatchedInserts(PreparedStatement.java:1593) 35 ... 9 common frames omitted 36 [2026-05-11 17:28:01.672] [WARN] [sinkTask-49] [Ignore current oms record [meta[monitor-stat_mq_queue_info_history,1778485053,INSERT,1778482891]post[Struct{id(INT64)=5226389095,tibco_alias(VAR_CHAR_STRING)=jq_cps_t,name(VAR_CHAR_STRING)=pic.bass.distributedEventQueue.amon-rudder-748964d779-clnht,url(VAR_CHAR_STRING)=tcp://tibco-cps-t01.99bill.com:7222,type(INT32)=1,static_tag(INT8)=0,receiver_count(INT32)=0,pending_msg_count(INT64)=1,pending_msg_size(INT64)=675,delivered_msg_count(INT64)=0,in_msg_rate(INT64)=0,in_bytes_rate(INT64)=0,in_total_bytes(INT64)=675,in_total_msgs(INT64)=1,out_msg_rate(INT64)=0,out_bytes_rate(INT64)=0,out_total_bytes(INT64)=0,out_total_msgs(INT64)=0,collect_time(DATETIME)=2026-05-11 15:37:00,create_time(DATETIME)=2026-05-11 15:37:32}]] for exception [Duplicate entry '5226389095' for key 'PRIMARY']] 37 [2026-05-11 17:28:01.673] [WARN] [sinkTask-12] [Ignore current oms record [meta[monitor-stat_mq_queue_info_history,1778485053,INSERT,1778482891]post[Struct{id(INT64)=5226389096,tibco_alias(VAR_CHAR_STRING)=jq_cps_t,name(VAR_CHAR_STRING)=pic.bass.distributedEventQueue.amon-rudder-748964d779-vqtbg,url(VAR_CHAR_STRING)=tcp://tibco-cps-t01.99bill.com:7222,type(INT32)=1,static_tag(INT8)=0,receiver_count(INT32)=0,pending_msg_count(INT64)=1,pending_msg_size(INT64)=673,delivered_msg_count(INT64)=0,in_msg_rate(INT64)=0,in_bytes_rate(INT64)=0,in_total_bytes(INT64)=673,in_total_msgs(INT64)=1,out_msg_rate(INT64)=0,out_bytes_rate(INT64)=0,out_total_bytes(INT64)=0,out_total_msgs(INT64)=0,collect_time(DATETIME)=2026-05-11 15:37:00,create_time(DATETIME)=2026-05-11 15:37:32}]] for exception [Duplicate entry '5226389096' for key 'PRIMARY']] 38 [2026-05-11 17:28:01.674] [INFO] [sinkTask-38] [batch replicate sql failed, use single statement replicate] 39 java.sql.BatchUpdateException: Duplicate entry '5226389097' for key 'PRIMARY' 40 at sun.reflect.GeneratedConstructorAccessor35.newInstance(Unknown Source) 41 at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) 42 at java.lang.reflect.Constructor.newInstance(Constructor.java:423) 43 at com.mysql.jdbc.Util.handleNewInstance(Util.java:425) 44 at com.mysql.jdbc.Util.getInstance(Util.java:408) 45 at com.mysql.jdbc.SQLError.createBatchUpdateException(SQLError.java:1163) 46 at com.mysql.jdbc.PreparedStatement.executeBatchedInserts(PreparedStatement.java:1632) 47 at com.mysql.jdbc.PreparedStatement.executeBatchInternal(PreparedStatement.java:1298) 48 at com.mysql.jdbc.StatementImpl.executeBatch(StatementImpl.java:970) 49 at com.alibaba.druid.pool.DruidPooledPreparedStatement.executeBatch(DruidPooledPreparedStatement.java:565) 50 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:265) 51 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:195) 52 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 53 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 54 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 55 at java.lang.Thread.run(Thread.java:853) 56 Caused by: com.mysql.jdbc.exceptions.jdbc4.MySQLIntegrityConstraintViolationException: Duplicate entry '5226389097' for key 'PRIMARY' 57 at sun.reflect.GeneratedConstructorAccessor27.newInstance(Unknown Source) 58 at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) 59 at java.lang.reflect.Constructor.newInstance(Constructor.java:423) 60 at com.mysql.jdbc.Util.handleNewInstance(Util.java:425) 61 at com.mysql.jdbc.Util.getInstance(Util.java:408) 62 at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:936) 63 at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3978) 64 at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3914) 65 at com.mysql.jdbc.MysqlIO.sendCommand(MysqlIO.java:2530) 66 at com.mysql.jdbc.MysqlIO.sqlQueryDirect(MysqlIO.java:2683) 67 at com.mysql.jdbc.ConnectionImpl.execSQL(ConnectionImpl.java:2495) 68 at com.mysql.jdbc.PreparedStatement.executeInternal(PreparedStatement.java:1903) 69 at com.mysql.jdbc.PreparedStatement.executeUpdateInternal(PreparedStatement.java:2124) 70 at com.mysql.jdbc.PreparedStatement.executeUpdateInternal(PreparedStatement.java:2058) 71 at com.mysql.jdbc.PreparedStatement.executeLargeUpdate(PreparedStatement.java:5158) 72 at com.mysql.jdbc.PreparedStatement.executeBatchedInserts(PreparedStatement.java:1593) 73 ... 9 common frames omitted 74 [2026-05-11 17:28:01.678] [WARN] [sinkTask-38] [Ignore current oms record [meta[monitor-stat_mq_queue_info_history,1778485053,INSERT,1778482891]post[Struct{id(INT64)=5226389097,tibco_alias(VAR_CHAR_STRING)=jq_cps_t,name(VAR_CHAR_STRING)=pic.bass.distributedEventQueue.amon-rudder-748964d779-xdmhf,url(VAR_CHAR_STRING)=tcp://tibco-cps-t01.99bill.com:7222,type(INT32)=1,static_tag(INT8)=0,receiver_count(INT32)=0,pending_msg_count(INT64)=1,pending_msg_size(INT64)=675,delivered_msg_count(INT64)=0,in_msg_rate(INT64)=0,in_bytes_rate(INT64)=0,in_total_bytes(INT64)=675,in_total_msgs(INT64)=1,out_msg_rate(INT64)=0,out_bytes_rate(INT64)=0,out_total_bytes(INT64)=0,out_total_msgs(INT64)=0,collect_time(DATETIME)=2026-05-11 15:37:00,create_time(DATETIME)=2026-05-11 15:37:32}]] for exception [Duplicate entry '5226389097' for key 'PRIMARY']] 75 [2026-05-11 17:28:01.679] [INFO] [sinkTask-35] [batch replicate sql failed, use single statement replicate] 76 java.sql.BatchUpdateException: Duplicate entry '5226389098' for key 'PRIMARY' 77 at sun.reflect.GeneratedConstructorAccessor35.newInstance(Unknown Source) 78 at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) 79 at java.lang.reflect.Constructor.newInstance(Constructor.java:423) 80 at com.mysql.jdbc.Util.handleNewInstance(Util.java:425) 81 at com.mysql.jdbc.Util.getInstance(Util.java:408) 82 at com.mysql.jdbc.SQLError.createBatchUpdateException(SQLError.java:1163) 83 at com.mysql.jdbc.PreparedStatement.executeBatchedInserts(PreparedStatement.java:1632) 84 at com.mysql.jdbc.PreparedStatement.executeBatchInternal(PreparedStatement.java:1298) 85 at com.mysql.jdbc.StatementImpl.executeBatch(StatementImpl.java:970) 86 at com.alibaba.druid.pool.DruidPooledPreparedStatement.executeBatch(DruidPooledPreparedStatement.java:565) 87 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:265) 88 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:195) 89 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 90 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 91 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 92 at java.lang.Thread.run(Thread.java:853) 93 Caused by: com.mysql.jdbc.exceptions.jdbc4.MySQLIntegrityConstraintViolationException: Duplicate entry '5226389098' for key 'PRIMARY' 94 at sun.reflect.GeneratedConstructorAccessor27.newInstance(Unknown Source) 95 at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) 96 at java.lang.reflect.Constructor.newInstance(Constructor.java:423) 97 at com.mysql.jdbc.Util.handleNewInstance(Util.java:425) 98 at com.mysql.jdbc.Util.getInstance(Util.java:408) 99 at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:936) 100 at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3978) 101 at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3914) 102 at com.mysql.jdbc.MysqlIO.sendCommand(MysqlIO.java:2530) 103 at com.mysql.jdbc.MysqlIO.sqlQueryDirect(MysqlIO.java:2683) 104 at com.mysql.jdbc.ConnectionImpl.execSQL(ConnectionImpl.java:2495) 105 at com.mysql.jdbc.PreparedStatement.executeInternal(PreparedStatement.java:1903) 106 at com.mysql.jdbc.PreparedStatement.executeUpdateInternal(PreparedStatement.java:2124) 107 at com.mysql.jdbc.PreparedStatement.executeUpdateInternal(PreparedStatement.java:2058) 108 at com.mysql.jdbc.PreparedStatement.executeLargeUpdate(PreparedStatement.java:5158) 109 at com.mysql.jdbc.PreparedStatement.executeBatchedInserts(PreparedStatement.java:1593) 110 ... 9 common frames omitted 111 [2026-05-11 17:28:01.680] [INFO] [sinkTask-29] [batch replicate sql failed, use single statement replicate] 112 java.sql.BatchUpdateException: Duplicate entry '5226389100' for key 'PRIMARY' 113 at sun.reflect.GeneratedConstructorAccessor35.newInstance(Unknown Source) 114 at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) 115 at java.lang.reflect.Constructor.newInstance(Constructor.java:423) 116 at com.mysql.jdbc.Util.handleNewInstance(Util.java:425) 117 at com.mysql.jdbc.Util.getInstance(Util.java:408) 118 at com.mysql.jdbc.SQLError.createBatchUpdateException(SQLError.java:1163) 119 at com.mysql.jdbc.PreparedStatement.executeBatchedInserts(PreparedStatement.java:1632) 120 at com.mysql.jdbc.PreparedStatement.executeBatchInternal(PreparedStatement.java:1298) 121 at com.mysql.jdbc.StatementImpl.executeBatch(StatementImpl.java:970) 122 at com.alibaba.druid.pool.DruidPooledPreparedStatement.executeBatch(DruidPooledPreparedStatement.java:565) 123 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:265) 124 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:195) 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: com.mysql.jdbc.exceptions.jdbc4.MySQLIntegrityConstraintViolationException: Duplicate entry '5226389100' for key 'PRIMARY' 130 at sun.reflect.GeneratedConstructorAccessor27.newInstance(Unknown Source) 131 at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) 132 at java.lang.reflect.Constructor.newInstance(Constructor.java:423) 133 at com.mysql.jdbc.Util.handleNewInstance(Util.java:425) 134 at com.mysql.jdbc.Util.getInstance(Util.java:408) 135 at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:936) 136 at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3978) 137 at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3914) 138 at com.mysql.jdbc.MysqlIO.sendCommand(MysqlIO.java:2530) 139 at com.mysql.jdbc.MysqlIO.sqlQueryDirect(MysqlIO.java:2683) 140 at com.mysql.jdbc.ConnectionImpl.execSQL(ConnectionImpl.java:2495) 141 at com.mysql.jdbc.PreparedStatement.executeInternal(PreparedStatement.java:1903) 142 at com.mysql.jdbc.PreparedStatement.executeUpdateInternal(PreparedStatement.java:2124) 143 at com.mysql.jdbc.PreparedStatement.executeUpdateInternal(PreparedStatement.java:2058) 144 at com.mysql.jdbc.PreparedStatement.executeLargeUpdate(PreparedStatement.java:5158) 145 at com.mysql.jdbc.PreparedStatement.executeBatchedInserts(PreparedStatement.java:1593) 146 ... 9 common frames omitted 147 [2026-05-11 17:28:01.680] [INFO] [sinkTask-27] [batch replicate sql failed, use single statement replicate] 148 java.sql.BatchUpdateException: Duplicate entry '5226389099' for key 'PRIMARY' 149 at sun.reflect.GeneratedConstructorAccessor35.newInstance(Unknown Source) 150 at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) 151 at java.lang.reflect.Constructor.newInstance(Constructor.java:423) 152 at com.mysql.jdbc.Util.handleNewInstance(Util.java:425) 153 at com.mysql.jdbc.Util.getInstance(Util.java:408) 154 at com.mysql.jdbc.SQLError.createBatchUpdateException(SQLError.java:1163) 155 at com.mysql.jdbc.PreparedStatement.executeBatchedInserts(PreparedStatement.java:1632) 156 at com.mysql.jdbc.PreparedStatement.executeBatchInternal(PreparedStatement.java:1298) 157 at com.mysql.jdbc.StatementImpl.executeBatch(StatementImpl.java:970) 158 at com.alibaba.druid.pool.DruidPooledPreparedStatement.executeBatch(DruidPooledPreparedStatement.java:565) 159 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:265) 160 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:195) 161 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 162 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 163 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 164 at java.lang.Thread.run(Thread.java:853) 165 Caused by: com.mysql.jdbc.exceptions.jdbc4.MySQLIntegrityConstraintViolationException: Duplicate entry '5226389099' for key 'PRIMARY' 166 at sun.reflect.GeneratedConstructorAccessor27.newInstance(Unknown Source) 167 at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) 168 at java.lang.reflect.Constructor.newInstance(Constructor.java:423) 169 at com.mysql.jdbc.Util.handleNewInstance(Util.java:425) 170 at com.mysql.jdbc.Util.getInstance(Util.java:408) 171 at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:936) 172 at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3978) 173 at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3914) 174 at com.mysql.jdbc.MysqlIO.sendCommand(MysqlIO.java:2530) 175 at com.mysql.jdbc.MysqlIO.sqlQueryDirect(MysqlIO.java:2683) 176 at com.mysql.jdbc.ConnectionImpl.execSQL(ConnectionImpl.java:2495) 177 at com.mysql.jdbc.PreparedStatement.executeInternal(PreparedStatement.java:1903) 178 at com.mysql.jdbc.PreparedStatement.executeUpdateInternal(PreparedStatement.java:2124) 179 at com.mysql.jdbc.PreparedStatement.executeUpdateInternal(PreparedStatement.java:2058) 180 at com.mysql.jdbc.PreparedStatement.executeLargeUpdate(PreparedStatement.java:5158) 181 at com.mysql.jdbc.PreparedStatement.executeBatchedInserts(PreparedStatement.java:1593) 182 ... 9 common frames omitted 183 [2026-05-11 17:28:01.680] [INFO] [sinkTask-17] [batch replicate sql failed, use single statement replicate] 184 java.sql.BatchUpdateException: Duplicate entry '5226389101' for key 'PRIMARY' 185 at sun.reflect.GeneratedConstructorAccessor35.newInstance(Unknown Source) 186 at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) 187 at java.lang.reflect.Constructor.newInstance(Constructor.java:423) 188 at com.mysql.jdbc.Util.handleNewInstance(Util.java:425) 189 at com.mysql.jdbc.Util.getInstance(Util.java:408) 190 at com.mysql.jdbc.SQLError.createBatchUpdateException(SQLError.java:1163) 191 at com.mysql.jdbc.PreparedStatement.executeBatchedInserts(PreparedStatement.java:1632) 192 at com.mysql.jdbc.PreparedStatement.executeBatchInternal(PreparedStatement.java:1298) 193 at com.mysql.jdbc.StatementImpl.executeBatch(StatementImpl.java:970) 194 at com.alibaba.druid.pool.DruidPooledPreparedStatement.executeBatch(DruidPooledPreparedStatement.java:565) 195 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:265) 196 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:195) 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 Caused by: com.mysql.jdbc.exceptions.jdbc4.MySQLIntegrityConstraintViolationException: Duplicate entry '5226389101' for key 'PRIMARY' 202 at sun.reflect.GeneratedConstructorAccessor27.newInstance(Unknown Source) 203 at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) 204 at java.lang.reflect.Constructor.newInstance(Constructor.java:423) 205 at com.mysql.jdbc.Util.handleNewInstance(Util.java:425) 206 at com.mysql.jdbc.Util.getInstance(Util.java:408) 207 at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:936) 208 at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3978) 209 at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3914) 210 at com.mysql.jdbc.MysqlIO.sendCommand(MysqlIO.java:2530) 211 at com.mysql.jdbc.MysqlIO.sqlQueryDirect(MysqlIO.java:2683) 212 at com.mysql.jdbc.ConnectionImpl.execSQL(ConnectionImpl.java:2495) 213 at com.mysql.jdbc.PreparedStatement.executeInternal(PreparedStatement.java:1903) 214 at com.mysql.jdbc.PreparedStatement.executeUpdateInternal(PreparedStatement.java:2124) 215 at com.mysql.jdbc.PreparedStatement.executeUpdateInternal(PreparedStatement.java:2058) 216 at com.mysql.jdbc.PreparedStatement.executeLargeUpdate(PreparedStatement.java:5158) 217 at com.mysql.jdbc.PreparedStatement.executeBatchedInserts(PreparedStatement.java:1593) 218 ... 9 common frames omitted 219 [2026-05-11 17:28:01.680] [INFO] [sinkTask-16] [batch replicate sql failed, use single statement replicate] 220 java.sql.BatchUpdateException: Duplicate entry '5226389102' for key 'PRIMARY' 221 at sun.reflect.GeneratedConstructorAccessor35.newInstance(Unknown Source) 222 at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) 223 at java.lang.reflect.Constructor.newInstance(Constructor.java:423) 224 at com.mysql.jdbc.Util.handleNewInstance(Util.java:425) 225 at com.mysql.jdbc.Util.getInstance(Util.java:408) 226 at com.mysql.jdbc.SQLError.createBatchUpdateException(SQLError.java:1163) 227 at com.mysql.jdbc.PreparedStatement.executeBatchedInserts(PreparedStatement.java:1632) 228 at com.mysql.jdbc.PreparedStatement.executeBatchInternal(PreparedStatement.java:1298) 229 at com.mysql.jdbc.StatementImpl.executeBatch(StatementImpl.java:970) 230 at com.alibaba.druid.pool.DruidPooledPreparedStatement.executeBatch(DruidPooledPreparedStatement.java:565) 231 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:265) 232 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:195) 233 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 234 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 235 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 236 at java.lang.Thread.run(Thread.java:853) 237 Caused by: com.mysql.jdbc.exceptions.jdbc4.MySQLIntegrityConstraintViolationException: Duplicate entry '5226389102' for key 'PRIMARY' 238 at sun.reflect.GeneratedConstructorAccessor27.newInstance(Unknown Source) 239 at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) 240 at java.lang.reflect.Constructor.newInstance(Constructor.java:423) 241 at com.mysql.jdbc.Util.handleNewInstance(Util.java:425) 242 at com.mysql.jdbc.Util.getInstance(Util.java:408) 243 at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:936) 244 at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3978) 245 at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3914) 246 at com.mysql.jdbc.MysqlIO.sendCommand(MysqlIO.java:2530) 247 at com.mysql.jdbc.MysqlIO.sqlQueryDirect(MysqlIO.java:2683) 248 at com.mysql.jdbc.ConnectionImpl.execSQL(ConnectionImpl.java:2495) 249 at com.mysql.jdbc.PreparedStatement.executeInternal(PreparedStatement.java:1903) 250 at com.mysql.jdbc.PreparedStatement.executeUpdateInternal(PreparedStatement.java:2124) 251 at com.mysql.jdbc.PreparedStatement.executeUpdateInternal(PreparedStatement.java:2058) 252 at com.mysql.jdbc.PreparedStatement.executeLargeUpdate(PreparedStatement.java:5158) 253 at com.mysql.jdbc.PreparedStatement.executeBatchedInserts(PreparedStatement.java:1593) 254 ... 9 common frames omitted 255 [2026-05-11 17:28:01.683] [WARN] [sinkTask-35] [Ignore current oms record [meta[monitor-stat_mq_queue_info_history,1778485053,INSERT,1778482891]post[Struct{id(INT64)=5226389098,tibco_alias(VAR_CHAR_STRING)=jq_cps_t,name(VAR_CHAR_STRING)=pic.bass.distributedEventQueue.amon-rudder-749bfc4988-8fm8r,url(VAR_CHAR_STRING)=tcp://tibco-cps-t01.99bill.com:7222,type(INT32)=1,static_tag(INT8)=0,receiver_count(INT32)=0,pending_msg_count(INT64)=1,pending_msg_size(INT64)=675,delivered_msg_count(INT64)=0,in_msg_rate(INT64)=0,in_bytes_rate(INT64)=0,in_total_bytes(INT64)=675,in_total_msgs(INT64)=1,out_msg_rate(INT64)=0,out_bytes_rate(INT64)=0,out_total_bytes(INT64)=0,out_total_msgs(INT64)=0,collect_time(DATETIME)=2026-05-11 15:37:00,create_time(DATETIME)=2026-05-11 15:37:32}]] for exception [Duplicate entry '5226389098' for key 'PRIMARY']] 256 [2026-05-11 17:28:01.683] [WARN] [sinkTask-29] [Ignore current oms record [meta[monitor-stat_mq_queue_info_history,1778485053,INSERT,1778482891]post[Struct{id(INT64)=5226389100,tibco_alias(VAR_CHAR_STRING)=jq_cps_t,name(VAR_CHAR_STRING)=pic.bass.distributedEventQueue.amon-rudder-749bfc4988-fmzdl,url(VAR_CHAR_STRING)=tcp://tibco-cps-t01.99bill.com:7222,type(INT32)=1,static_tag(INT8)=0,receiver_count(INT32)=0,pending_msg_count(INT64)=1,pending_msg_size(INT64)=673,delivered_msg_count(INT64)=0,in_msg_rate(INT64)=0,in_bytes_rate(INT64)=0,in_total_bytes(INT64)=673,in_total_msgs(INT64)=1,out_msg_rate(INT64)=0,out_bytes_rate(INT64)=0,out_total_bytes(INT64)=0,out_total_msgs(INT64)=0,collect_time(DATETIME)=2026-05-11 15:37:00,create_time(DATETIME)=2026-05-11 15:37:32}]] for exception [Duplicate entry '5226389100' for key 'PRIMARY']] 257 [2026-05-11 17:28:01.683] [WARN] [sinkTask-27] [Ignore current oms record [meta[monitor-stat_mq_queue_info_history,1778485053,INSERT,1778482891]post[Struct{id(INT64)=5226389099,tibco_alias(VAR_CHAR_STRING)=jq_cps_t,name(VAR_CHAR_STRING)=pic.bass.distributedEventQueue.amon-rudder-749bfc4988-97tsq,url(VAR_CHAR_STRING)=tcp://tibco-cps-t01.99bill.com:7222,type(INT32)=1,static_tag(INT8)=0,receiver_count(INT32)=0,pending_msg_count(INT64)=1,pending_msg_size(INT64)=675,delivered_msg_count(INT64)=0,in_msg_rate(INT64)=0,in_bytes_rate(INT64)=0,in_total_bytes(INT64)=675,in_total_msgs(INT64)=1,out_msg_rate(INT64)=0,out_bytes_rate(INT64)=0,out_total_bytes(INT64)=0,out_total_msgs(INT64)=0,collect_time(DATETIME)=2026-05-11 15:37:00,create_time(DATETIME)=2026-05-11 15:37:32}]] for exception [Duplicate entry '5226389099' for key 'PRIMARY']] 258 [2026-05-11 17:28:01.684] [WARN] [sinkTask-16] [Ignore current oms record [meta[monitor-stat_mq_queue_info_history,1778485053,INSERT,1778482891]post[Struct{id(INT64)=5226389102,tibco_alias(VAR_CHAR_STRING)=jq_cps_t,name(VAR_CHAR_STRING)=pic.bass.distributedEventQueue.amon-rudder-74b5db8457-8hlfs,url(VAR_CHAR_STRING)=tcp://tibco-cps-t01.99bill.com:7222,type(INT32)=1,static_tag(INT8)=0,receiver_count(INT32)=0,pending_msg_count(INT64)=1,pending_msg_size(INT64)=677,delivered_msg_count(INT64)=0,in_msg_rate(INT64)=0,in_bytes_rate(INT64)=0,in_total_bytes(INT64)=677,in_total_msgs(INT64)=1,out_msg_rate(INT64)=0,out_bytes_rate(INT64)=0,out_total_bytes(INT64)=0,out_total_msgs(INT64)=0,collect_time(DATETIME)=2026-05-11 15:37:00,create_time(DATETIME)=2026-05-11 15:37:32}]] for exception [Duplicate entry '5226389102' for key 'PRIMARY']] 259 [2026-05-11 17:28:01.684] [WARN] [sinkTask-17] [Ignore current oms record [meta[monitor-stat_mq_queue_info_history,1778485053,INSERT,1778482891]post[Struct{id(INT64)=5226389101,tibco_alias(VAR_CHAR_STRING)=jq_cps_t,name(VAR_CHAR_STRING)=pic.bass.distributedEventQueue.amon-rudder-749bfc4988-wfkcs,url(VAR_CHAR_STRING)=tcp://tibco-cps-t01.99bill.com:7222,type(INT32)=1,static_tag(INT8)=0,receiver_count(INT32)=0,pending_msg_count(INT64)=1,pending_msg_size(INT64)=675,delivered_msg_count(INT64)=0,in_msg_rate(INT64)=0,in_bytes_rate(INT64)=0,in_total_bytes(INT64)=675,in_total_msgs(INT64)=1,out_msg_rate(INT64)=0,out_bytes_rate(INT64)=0,out_total_bytes(INT64)=0,out_total_msgs(INT64)=0,collect_time(DATETIME)=2026-05-11 15:37:00,create_time(DATETIME)=2026-05-11 15:37:32}]] for exception [Duplicate entry '5226389101' for key 'PRIMARY']] 260 [2026-05-11 17:28:01.684] [INFO] [sinkTask-59] [batch replicate sql failed, use single statement replicate] 261 java.sql.BatchUpdateException: Duplicate entry '5226389103' for key 'PRIMARY' 262 at sun.reflect.GeneratedConstructorAccessor35.newInstance(Unknown Source) 263 at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) 264 at java.lang.reflect.Constructor.newInstance(Constructor.java:423) 265 at com.mysql.jdbc.Util.handleNewInstance(Util.java:425) 266 at com.mysql.jdbc.Util.getInstance(Util.java:408) 267 at com.mysql.jdbc.SQLError.createBatchUpdateException(SQLError.java:1163) 268 at com.mysql.jdbc.PreparedStatement.executeBatchedInserts(PreparedStatement.java:1632) 269 at com.mysql.jdbc.PreparedStatement.executeBatchInternal(PreparedStatement.java:1298) 270 at com.mysql.jdbc.StatementImpl.executeBatch(StatementImpl.java:970) 271 at com.alibaba.druid.pool.DruidPooledPreparedStatement.executeBatch(DruidPooledPreparedStatement.java:565) 272 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:265) 273 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:195) 274 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 275 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 276 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 277 at java.lang.Thread.run(Thread.java:853) 278 Caused by: com.mysql.jdbc.exceptions.jdbc4.MySQLIntegrityConstraintViolationException: Duplicate entry '5226389103' for key 'PRIMARY' 279 at sun.reflect.GeneratedConstructorAccessor27.newInstance(Unknown Source) 280 at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) 281 at java.lang.reflect.Constructor.newInstance(Constructor.java:423) 282 at com.mysql.jdbc.Util.handleNewInstance(Util.java:425) 283 at com.mysql.jdbc.Util.getInstance(Util.java:408) 284 at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:936) 285 at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3978) 286 at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3914) 287 at com.mysql.jdbc.MysqlIO.sendCommand(MysqlIO.java:2530) 288 at com.mysql.jdbc.MysqlIO.sqlQueryDirect(MysqlIO.java:2683) 289 at com.mysql.jdbc.ConnectionImpl.execSQL(ConnectionImpl.java:2495) 290 at com.mysql.jdbc.PreparedStatement.executeInternal(PreparedStatement.java:1903) 291 at com.mysql.jdbc.PreparedStatement.executeUpdateInternal(PreparedStatement.java:2124) 292 at com.mysql.jdbc.PreparedStatement.executeUpdateInternal(PreparedStatement.java:2058) 293 at com.mysql.jdbc.PreparedStatement.executeLargeUpdate(PreparedStatement.java:5158) 294 at com.mysql.jdbc.PreparedStatement.executeBatchedInserts(PreparedStatement.java:1593) 295 ... 9 common frames omitted 296 [2026-05-11 17:28:01.688] [WARN] [sinkTask-59] [Ignore current oms record [meta[monitor-stat_mq_queue_info_history,1778485053,INSERT,1778482891]post[Struct{id(INT64)=5226389103,tibco_alias(VAR_CHAR_STRING)=jq_cps_t,name(VAR_CHAR_STRING)=pic.bass.distributedEventQueue.amon-rudder-74b5db8457-vj77n,url(VAR_CHAR_STRING)=tcp://tibco-cps-t01.99bill.com:7222,type(INT32)=1,static_tag(INT8)=0,receiver_count(INT32)=0,pending_msg_count(INT64)=1,pending_msg_size(INT64)=675,delivered_msg_count(INT64)=0,in_msg_rate(INT64)=0,in_bytes_rate(INT64)=0,in_total_bytes(INT64)=675,in_total_msgs(INT64)=1,out_msg_rate(INT64)=0,out_bytes_rate(INT64)=0,out_total_bytes(INT64)=0,out_total_msgs(INT64)=0,collect_time(DATETIME)=2026-05-11 15:37:00,create_time(DATETIME)=2026-05-11 15:37:32}]] for exception [Duplicate entry '5226389103' for key 'PRIMARY']] 297 [2026-05-11 17:28:01.690] [INFO] [sinkTask-45] [batch replicate sql failed, use single statement replicate] 298 java.sql.BatchUpdateException: Duplicate entry '5226389104' for key 'PRIMARY' 299 at sun.reflect.GeneratedConstructorAccessor35.newInstance(Unknown Source) 300 at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) 301 at java.lang.reflect.Constructor.newInstance(Constructor.java:423) 302 at com.mysql.jdbc.Util.handleNewInstance(Util.java:425) 303 at com.mysql.jdbc.Util.getInstance(Util.java:408) 304 at com.mysql.jdbc.SQLError.createBatchUpdateException(SQLError.java:1163) 305 at com.mysql.jdbc.PreparedStatement.executeBatchedInserts(PreparedStatement.java:1632) 306 at com.mysql.jdbc.PreparedStatement.executeBatchInternal(PreparedStatement.java:1298) 307 at com.mysql.jdbc.StatementImpl.executeBatch(StatementImpl.java:970) 308 at com.alibaba.druid.pool.DruidPooledPreparedStatement.executeBatch(DruidPooledPreparedStatement.java:565) 309 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:265) 310 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:195) 311 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 312 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 313 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 314 at java.lang.Thread.run(Thread.java:853) 315 Caused by: com.mysql.jdbc.exceptions.jdbc4.MySQLIntegrityConstraintViolationException: Duplicate entry '5226389104' for key 'PRIMARY' 316 at sun.reflect.GeneratedConstructorAccessor27.newInstance(Unknown Source) 317 at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) 318 at java.lang.reflect.Constructor.newInstance(Constructor.java:423) 319 at com.mysql.jdbc.Util.handleNewInstance(Util.java:425) 320 at com.mysql.jdbc.Util.getInstance(Util.java:408) 321 at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:936) 322 at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3978) 323 at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3914) 324 at com.mysql.jdbc.MysqlIO.sendCommand(MysqlIO.java:2530) 325 at com.mysql.jdbc.MysqlIO.sqlQueryDirect(MysqlIO.java:2683) 326 at com.mysql.jdbc.ConnectionImpl.execSQL(ConnectionImpl.java:2495) 327 at com.mysql.jdbc.PreparedStatement.executeInternal(PreparedStatement.java:1903) 328 at com.mysql.jdbc.PreparedStatement.executeUpdateInternal(PreparedStatement.java:2124) 329 at com.mysql.jdbc.PreparedStatement.executeUpdateInternal(PreparedStatement.java:2058) 330 at com.mysql.jdbc.PreparedStatement.executeLargeUpdate(PreparedStatement.java:5158) 331 at com.mysql.jdbc.PreparedStatement.executeBatchedInserts(PreparedStatement.java:1593) 332 ... 9 common frames omitted 333 [2026-05-11 17:28:01.694] [WARN] [sinkTask-45] [Ignore current oms record [meta[monitor-stat_mq_queue_info_history,1778485053,INSERT,1778482891]post[Struct{id(INT64)=5226389104,tibco_alias(VAR_CHAR_STRING)=jq_cps_t,name(VAR_CHAR_STRING)=pic.bass.distributedEventQueue.amon-rudder-74bd88b6bc-blf74,url(VAR_CHAR_STRING)=tcp://tibco-cps-t01.99bill.com:7222,type(INT32)=1,static_tag(INT8)=0,receiver_count(INT32)=0,pending_msg_count(INT64)=1,pending_msg_size(INT64)=675,delivered_msg_count(INT64)=0,in_msg_rate(INT64)=0,in_bytes_rate(INT64)=0,in_total_bytes(INT64)=675,in_total_msgs(INT64)=1,out_msg_rate(INT64)=0,out_bytes_rate(INT64)=0,out_total_bytes(INT64)=0,out_total_msgs(INT64)=0,collect_time(DATETIME)=2026-05-11 15:37:00,create_time(DATETIME)=2026-05-11 15:37:32}]] for exception [Duplicate entry '5226389104' for key 'PRIMARY']] 334 [2026-05-11 17:28:01.695] [INFO] [sinkTask-34] [batch replicate sql failed, use single statement replicate] 335 java.sql.BatchUpdateException: Duplicate entry '5226389105' for key 'PRIMARY' 336 at sun.reflect.GeneratedConstructorAccessor35.newInstance(Unknown Source) 337 at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) 338 at java.lang.reflect.Constructor.newInstance(Constructor.java:423) 339 at com.mysql.jdbc.Util.handleNewInstance(Util.java:425) 340 at com.mysql.jdbc.Util.getInstance(Util.java:408) 341 at com.mysql.jdbc.SQLError.createBatchUpdateException(SQLError.java:1163) 342 at com.mysql.jdbc.PreparedStatement.executeBatchedInserts(PreparedStatement.java:1632) 343 at com.mysql.jdbc.PreparedStatement.executeBatchInternal(PreparedStatement.java:1298) 344 at com.mysql.jdbc.StatementImpl.executeBatch(StatementImpl.java:970) 345 at com.alibaba.druid.pool.DruidPooledPreparedStatement.executeBatch(DruidPooledPreparedStatement.java:565) 346 at com.oceanbase.oms.connector.jdbc.sink.Writer.batchFlushDML(Writer.java:265) 347 at com.oceanbase.oms.connector.jdbc.sink.Writer.flushRecords(Writer.java:195) 348 at com.oceanbase.oms.connector.jdbc.sink.DefaultJDBCSink.offer(DefaultJDBCSink.java:60) 349 at com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSink.offer(OBMySQLJDBCSink.java:25) 350 at com.oceanbase.connector.framework.threadmanager.sinktask.SyncSinkConnectorTask.run(SyncSinkConnectorTask.java:47) 351 at java.lang.Thread.run(Thread.java:853) 352 Caused by: com.mysql.jdbc.exceptions.jdbc4.MySQLIntegrityConstraintViolationException: Duplicate entry '5226389105' for key 'PRIMARY' 353 at sun.reflect.GeneratedConstructorAccessor27.newInstance(Unknown Source) 354 at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) 355 at java.lang.reflect.Constructor.newInstance(Constructor.java:423) 356 at com.mysql.jdbc.Util.handleNewInstance(Util.java:425) 357 at com.mysql.jdbc.Util.getInstance(Util.java:408) 358 at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:936) 359 at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3978) 360 at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3914) 361 at com.mysql.jdbc.MysqlIO.sendCommand(MysqlIO.java:2530) 362 at com.mysql.jdbc.MysqlIO.sqlQueryDirect(MysqlIO.java:2683) 363 at com.mysql.jdbc.ConnectionImpl.execSQL(ConnectionImpl.java:2495) 364 at com.mysql.jdbc.PreparedStatement.executeInternal(PreparedStatement.java:1903) 365 at com.mysql.jdbc.PreparedStatement.executeUpdateInternal(PreparedStatement.java:2124) 366 at com.mysql.jdbc.PreparedStatement.executeUpdateInternal(PreparedStatement.java:2058) 367 at com.mysql.jdbc.PreparedStatement.executeLargeUpdate(PreparedStatement.java:5158) 368 at com.mysql.jdbc.PreparedStatement.executeBatchedInserts(PreparedStatement.java:1593) 369 ... 9 common frames omitted 370 [2026-05-11 17:28:01.699] [WARN] [sinkTask-34] [Ignore current oms record [meta[monitor-stat_mq_queue_info_history,1778485053,INSERT,1778482891]post[Struct{id(INT64)=5226389105,tibco_alias(VAR_CHAR_STRING)=jq_cps_t,name(VAR_CHAR_STRING)=pic.bass.distributedEventQueue.amon-rudder-74bd88b6bc-xs9vk,url(VAR_CHAR_STRING)=tcp://tibco-cps-t01.99bill.com:7222,type(INT32)=1,static_tag(INT8)=0,receiver_count(INT32)=0,pending_msg_count(INT64)=1,pending_msg_size(INT64)=675,delivered_msg_count(INT64)=0,in_msg_rate(INT64)=0,in_bytes_rate(INT64)=0,in_total_bytes(INT64)=675,in_total_msgs(INT64)=1,out_msg_rate(INT64)=0,out_bytes_rate(INT64)=0,out_total_bytes(INT64)=0,out_total_msgs(INT64)=0,collect_time(DATETIME)=2026-05-11 15:37:00,create_time(DATETIME)=2026-05-11 15:37:32}]] for exception [Duplicate entry '5226389105' for key 'PRIMARY']] 371 [2026-05-11 17:28:19.394] [INFO] [forward_slot0-(ETLProcessor)-queue_slot1] [table name [t_amon_txn_qr_029] set for ddl [create /*+ parallel(4) */ index if not exists `IDX_AMONQR_TXN_TIME` on `t_amon_txn_qr_029` (`TXN_TIME` ASC) LOCAL]] 372 [2026-05-11 17:28:19.394] [WARN] [forward_slot0-(ETLProcessor)-queue_slot1] [DDLTransfer: ddl should be filtered, dbname:ate.ate, ddl: create /*+ parallel(4) */ index if not exists `IDX_AMONQR_TXN_TIME` on `t_amon_txn_qr_029` (`TXN_TIME` ASC) LOCAL] 373 [2026-05-11 17:28:19.394] [INFO] [forward_slot0-(ETLProcessor)-queue_slot1] [DDLTransfer: ddl create /*+ parallel(4) */ index if not exists `IDX_AMONQR_TXN_TIME` on `t_amon_txn_qr_029` (`TXN_TIME` ASC) LOCAL filter with map db null, with record db [ate.ate], table [null], parsed db[ate.ate], table[t_amon_txn_qr_029], dbToMap[ate.ate], tbToMap[t_amon_txn_qr_029]] 374 [2026-05-11 17:28:42.298] [WARN] [DRC-Client-Thread] [transaction is 1018_40274806, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 375 [2026-05-11 17:28:42.299] [WARN] [DRC-Client-Thread] [transaction is 1018_40274806, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 376 [2026-05-11 17:28:42.300] [WARN] [DRC-Client-Thread] [transaction is 1018_40274806, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 377 [2026-05-11 17:28:42.300] [WARN] [DRC-Client-Thread] [transaction is 1018_40274806, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 378 [2026-05-11 17:28:42.301] [WARN] [DRC-Client-Thread] [transaction is 1018_40274806, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 379 [2026-05-11 17:28:42.302] [WARN] [DRC-Client-Thread] [transaction is 1018_40274806, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 380 [2026-05-11 17:28:42.303] [WARN] [DRC-Client-Thread] [transaction is 1018_40274806, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 381 [2026-05-11 17:28:42.304] [WARN] [DRC-Client-Thread] [transaction is 1018_40274806, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 382 [2026-05-11 17:28:42.305] [WARN] [DRC-Client-Thread] [transaction is 1018_40274806, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 383 [2026-05-11 17:28:42.305] [WARN] [DRC-Client-Thread] [transaction is 1018_40274806, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 384 [2026-05-11 17:28:42.306] [WARN] [DRC-Client-Thread] [transaction is 1018_40274806, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 385 [2026-05-11 17:28:42.307] [WARN] [DRC-Client-Thread] [transaction is 1018_40274806, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 386 [2026-05-11 17:28:42.308] [WARN] [DRC-Client-Thread] [transaction is 1018_40274806, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 387 [2026-05-11 17:28:42.308] [WARN] [DRC-Client-Thread] [transaction is 1018_40274806, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 388 [2026-05-11 17:28:42.309] [WARN] [DRC-Client-Thread] [transaction is 1018_40274806, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 389 [2026-05-11 17:28:42.310] [WARN] [DRC-Client-Thread] [transaction is 1018_40274806, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 390 [2026-05-11 17:28:42.311] [WARN] [DRC-Client-Thread] [transaction is 1018_40274806, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 391 [2026-05-11 17:28:42.312] [WARN] [DRC-Client-Thread] [transaction is 1018_40274806, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 392 [2026-05-11 17:28:42.313] [WARN] [DRC-Client-Thread] [transaction is 1018_40274806, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 393 [2026-05-11 17:28:42.314] [WARN] [DRC-Client-Thread] [transaction is 1018_40274806, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 394 [2026-05-11 17:28:42.315] [WARN] [DRC-Client-Thread] [transaction is 1018_40274806, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 395 [2026-05-11 17:28:42.316] [WARN] [DRC-Client-Thread] [transaction is 1018_40274806, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 396 [2026-05-11 17:28:42.317] [WARN] [DRC-Client-Thread] [transaction is 1018_40274806, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 397 [2026-05-11 17:28:42.319] [WARN] [DRC-Client-Thread] [transaction is 1018_40274806, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 398 [2026-05-11 17:28:42.320] [WARN] [DRC-Client-Thread] [transaction is 1018_40274806, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 399 [2026-05-11 17:28:42.321] [WARN] [DRC-Client-Thread] [transaction is 1018_40274806, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 400 [2026-05-11 17:28:42.322] [WARN] [DRC-Client-Thread] [transaction is 1018_40274806, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 401 [2026-05-11 17:28:42.323] [WARN] [DRC-Client-Thread] [transaction is 1018_40274806, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 402 [2026-05-11 17:28:42.324] [WARN] [DRC-Client-Thread] [transaction is 1018_40274806, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 403 [2026-05-11 17:28:42.325] [WARN] [DRC-Client-Thread] [transaction is 1018_40274806, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 404 [2026-05-11 17:28:42.326] [WARN] [DRC-Client-Thread] [transaction is 1018_40274806, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 405 [2026-05-11 17:28:44.910] [INFO] [forward_slot0-(ETLProcessor)-queue_slot1] [table name [t_amon_txn_qr_031] set for ddl [create /*+ parallel(4) */ index if not exists `IDX_AMONQR_ID_TXN` on `t_amon_txn_qr_031` (`ID_TXN` ASC) LOCAL]] 406 [2026-05-11 17:28:44.910] [WARN] [forward_slot0-(ETLProcessor)-queue_slot1] [DDLTransfer: ddl should be filtered, dbname:ate.ate, ddl: create /*+ parallel(4) */ index if not exists `IDX_AMONQR_ID_TXN` on `t_amon_txn_qr_031` (`ID_TXN` ASC) LOCAL] 407 [2026-05-11 17:28:44.910] [INFO] [forward_slot0-(ETLProcessor)-queue_slot1] [DDLTransfer: ddl create /*+ parallel(4) */ index if not exists `IDX_AMONQR_ID_TXN` on `t_amon_txn_qr_031` (`ID_TXN` ASC) LOCAL filter with map db null, with record db [ate.ate], table [null], parsed db[ate.ate], table[t_amon_txn_qr_031], dbToMap[ate.ate], tbToMap[t_amon_txn_qr_031]] 408 [2026-05-11 17:28:47.095] [WARN] [DRC-Client-Thread] [transaction is 1018_40278287, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 409 [2026-05-11 17:28:47.095] [WARN] [DRC-Client-Thread] [transaction is 1018_40278287, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 410 [2026-05-11 17:28:47.096] [WARN] [DRC-Client-Thread] [transaction is 1018_40278287, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 411 [2026-05-11 17:28:47.097] [WARN] [DRC-Client-Thread] [transaction is 1018_40278287, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 412 [2026-05-11 17:28:47.098] [WARN] [DRC-Client-Thread] [transaction is 1018_40278287, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 413 [2026-05-11 17:28:47.099] [WARN] [DRC-Client-Thread] [transaction is 1018_40278287, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 414 [2026-05-11 17:28:47.100] [WARN] [DRC-Client-Thread] [transaction is 1018_40278287, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 415 [2026-05-11 17:28:47.101] [WARN] [DRC-Client-Thread] [transaction is 1018_40278287, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 416 [2026-05-11 17:28:47.102] [WARN] [DRC-Client-Thread] [transaction is 1018_40278287, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 417 [2026-05-11 17:28:47.103] [WARN] [DRC-Client-Thread] [transaction is 1018_40278287, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 418 [2026-05-11 17:28:47.104] [WARN] [DRC-Client-Thread] [transaction is 1018_40278287, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 419 [2026-05-11 17:28:47.105] [WARN] [DRC-Client-Thread] [transaction is 1018_40278287, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 420 [2026-05-11 17:28:47.106] [WARN] [DRC-Client-Thread] [transaction is 1018_40278287, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 421 [2026-05-11 17:28:47.107] [WARN] [DRC-Client-Thread] [transaction is 1018_40278287, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 422 [2026-05-11 17:28:47.108] [WARN] [DRC-Client-Thread] [transaction is 1018_40278287, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 423 [2026-05-11 17:28:47.109] [WARN] [DRC-Client-Thread] [transaction is 1018_40278287, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 424 [2026-05-11 17:28:47.110] [WARN] [DRC-Client-Thread] [transaction is 1018_40278287, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 425 [2026-05-11 17:28:47.111] [WARN] [DRC-Client-Thread] [transaction is 1018_40278287, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 426 [2026-05-11 17:28:47.112] [WARN] [DRC-Client-Thread] [transaction is 1018_40278287, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 427 [2026-05-11 17:28:47.113] [WARN] [DRC-Client-Thread] [transaction is 1018_40278287, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 428 [2026-05-11 17:28:47.114] [WARN] [DRC-Client-Thread] [transaction is 1018_40278287, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 429 [2026-05-11 17:28:47.115] [WARN] [DRC-Client-Thread] [transaction is 1018_40278287, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 430 [2026-05-11 17:28:47.117] [WARN] [DRC-Client-Thread] [transaction is 1018_40278287, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 431 [2026-05-11 17:28:47.118] [WARN] [DRC-Client-Thread] [transaction is 1018_40278287, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 432 [2026-05-11 17:28:47.119] [WARN] [DRC-Client-Thread] [transaction is 1018_40278287, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 433 [2026-05-11 17:28:47.120] [WARN] [DRC-Client-Thread] [transaction is 1018_40278287, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 434 [2026-05-11 17:28:47.121] [WARN] [DRC-Client-Thread] [transaction is 1018_40278287, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 435 [2026-05-11 17:28:47.122] [WARN] [DRC-Client-Thread] [transaction is 1018_40278287, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 436 [2026-05-11 17:28:47.123] [WARN] [DRC-Client-Thread] [transaction is 1018_40278287, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 437 [2026-05-11 17:28:47.124] [WARN] [DRC-Client-Thread] [transaction is 1018_40278287, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 438 [2026-05-11 17:28:47.125] [WARN] [DRC-Client-Thread] [transaction is 1018_40278287, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 439 [2026-05-11 17:28:50.802] [WARN] [DRC-Client-Thread] [transaction is 1018_40281342, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 440 [2026-05-11 17:28:50.803] [WARN] [DRC-Client-Thread] [transaction is 1018_40281342, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 441 [2026-05-11 17:28:50.806] [WARN] [DRC-Client-Thread] [transaction is 1018_40281342, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 442 [2026-05-11 17:28:50.808] [WARN] [DRC-Client-Thread] [transaction is 1018_40281342, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 443 [2026-05-11 17:28:50.809] [WARN] [DRC-Client-Thread] [transaction is 1018_40281342, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 444 [2026-05-11 17:28:50.810] [WARN] [DRC-Client-Thread] [transaction is 1018_40281342, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 445 [2026-05-11 17:28:50.811] [WARN] [DRC-Client-Thread] [transaction is 1018_40281342, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 446 [2026-05-11 17:28:50.812] [WARN] [DRC-Client-Thread] [transaction is 1018_40281342, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 447 [2026-05-11 17:28:50.813] [WARN] [DRC-Client-Thread] [transaction is 1018_40281342, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 448 [2026-05-11 17:28:50.814] [WARN] [DRC-Client-Thread] [transaction is 1018_40281342, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 449 [2026-05-11 17:28:50.815] [WARN] [DRC-Client-Thread] [transaction is 1018_40281342, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 450 [2026-05-11 17:28:50.817] [WARN] [DRC-Client-Thread] [transaction is 1018_40281342, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 451 [2026-05-11 17:28:50.818] [WARN] [DRC-Client-Thread] [transaction is 1018_40281342, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 452 [2026-05-11 17:28:50.819] [WARN] [DRC-Client-Thread] [transaction is 1018_40281342, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 453 [2026-05-11 17:28:50.820] [WARN] [DRC-Client-Thread] [transaction is 1018_40281342, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 454 [2026-05-11 17:28:50.821] [WARN] [DRC-Client-Thread] [transaction is 1018_40281342, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 455 [2026-05-11 17:28:50.821] [WARN] [DRC-Client-Thread] [transaction is 1018_40281342, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 456 [2026-05-11 17:28:50.822] [WARN] [DRC-Client-Thread] [transaction is 1018_40281342, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 457 [2026-05-11 17:28:50.823] [WARN] [DRC-Client-Thread] [transaction is 1018_40281342, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 458 [2026-05-11 17:28:50.824] [WARN] [DRC-Client-Thread] [transaction is 1018_40281342, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 459 [2026-05-11 17:28:50.824] [WARN] [DRC-Client-Thread] [transaction is 1018_40281342, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 460 [2026-05-11 17:28:50.825] [WARN] [DRC-Client-Thread] [transaction is 1018_40281342, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 461 [2026-05-11 17:28:50.826] [WARN] [DRC-Client-Thread] [transaction is 1018_40281342, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 462 [2026-05-11 17:28:50.827] [WARN] [DRC-Client-Thread] [transaction is 1018_40281342, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 463 [2026-05-11 17:28:50.828] [WARN] [DRC-Client-Thread] [transaction is 1018_40281342, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 464 [2026-05-11 17:28:50.829] [WARN] [DRC-Client-Thread] [transaction is 1018_40281342, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 465 [2026-05-11 17:28:50.830] [WARN] [DRC-Client-Thread] [transaction is 1018_40281342, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 466 [2026-05-11 17:28:50.832] [WARN] [DRC-Client-Thread] [transaction is 1018_40281342, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 467 [2026-05-11 17:28:50.833] [WARN] [DRC-Client-Thread] [transaction is 1018_40281342, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 468 [2026-05-11 17:28:50.833] [WARN] [DRC-Client-Thread] [transaction is 1018_40281342, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 469 [2026-05-11 17:28:50.834] [WARN] [DRC-Client-Thread] [transaction is 1018_40281342, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 470 [2026-05-11 17:28:52.666] [INFO] [DRC-Client-Thread] [notify consume: 0.018659774317594403 ms] 471 [2026-05-11 17:28:54.357] [WARN] [DRC-Client-Thread] [transaction is 1018_40284753, tableName is mq_collect_data, maxRecords is 64, cut it] 472 [2026-05-11 17:28:54.358] [WARN] [DRC-Client-Thread] [transaction is 1018_40284753, tableName is mq_collect_data, maxRecords is 64, cut it] 473 [2026-05-11 17:28:54.359] [WARN] [DRC-Client-Thread] [transaction is 1018_40284753, tableName is mq_collect_data, maxRecords is 64, cut it] 474 [2026-05-11 17:28:54.360] [WARN] [DRC-Client-Thread] [transaction is 1018_40284753, tableName is mq_collect_data, maxRecords is 64, cut it] 475 [2026-05-11 17:28:54.362] [WARN] [DRC-Client-Thread] [transaction is 1018_40284753, tableName is mq_collect_data, maxRecords is 64, cut it] 476 [2026-05-11 17:28:54.363] [WARN] [DRC-Client-Thread] [transaction is 1018_40284753, tableName is mq_collect_data, maxRecords is 64, cut it] 477 [2026-05-11 17:28:54.364] [WARN] [DRC-Client-Thread] [transaction is 1018_40284753, tableName is mq_collect_data, maxRecords is 64, cut it] 478 [2026-05-11 17:28:54.366] [WARN] [DRC-Client-Thread] [transaction is 1018_40284753, tableName is mq_collect_data, maxRecords is 64, cut it] 479 [2026-05-11 17:28:54.367] [WARN] [DRC-Client-Thread] [transaction is 1018_40284753, tableName is mq_collect_data, maxRecords is 64, cut it] 480 [2026-05-11 17:28:54.368] [WARN] [DRC-Client-Thread] [transaction is 1018_40284753, tableName is mq_collect_data, maxRecords is 64, cut it] 481 [2026-05-11 17:28:57.025] [INFO] [forward_slot0-(ETLProcessor)-queue_slot1] [table name [t_amon_txn_qr_031] set for ddl [create /*+ parallel(4) */ index if not exists `IDX_AMONQR_MER_ID_EXTNO` on `t_amon_txn_qr_031` (`MERCHANT_ID` ASC, `EXT_TRACE_NO` ASC) LOCAL]] 482 [2026-05-11 17:28:57.025] [WARN] [forward_slot0-(ETLProcessor)-queue_slot1] [DDLTransfer: ddl should be filtered, dbname:ate.ate, ddl: create /*+ parallel(4) */ index if not exists `IDX_AMONQR_MER_ID_EXTNO` on `t_amon_txn_qr_031` (`MERCHANT_ID` ASC, `EXT_TRACE_NO` ASC) LOCAL] 483 [2026-05-11 17:28:57.025] [INFO] [forward_slot0-(ETLProcessor)-queue_slot1] [DDLTransfer: ddl create /*+ parallel(4) */ index if not exists `IDX_AMONQR_MER_ID_EXTNO` on `t_amon_txn_qr_031` (`MERCHANT_ID` ASC, `EXT_TRACE_NO` ASC) LOCAL filter with map db null, with record db [ate.ate], table [null], parsed db[ate.ate], table[t_amon_txn_qr_031], dbToMap[ate.ate], tbToMap[t_amon_txn_qr_031]] 484 [2026-05-11 17:28:57.083] [WARN] [DRC-Client-Thread] [transaction is 1018_40284768, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 485 [2026-05-11 17:28:57.084] [WARN] [DRC-Client-Thread] [transaction is 1018_40284768, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 486 [2026-05-11 17:28:57.085] [WARN] [DRC-Client-Thread] [transaction is 1018_40284768, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 487 [2026-05-11 17:28:57.087] [WARN] [DRC-Client-Thread] [transaction is 1018_40284768, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 488 [2026-05-11 17:28:57.089] [WARN] [DRC-Client-Thread] [transaction is 1018_40284768, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 489 [2026-05-11 17:28:57.090] [WARN] [DRC-Client-Thread] [transaction is 1018_40284768, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 490 [2026-05-11 17:28:57.092] [WARN] [DRC-Client-Thread] [transaction is 1018_40284768, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 491 [2026-05-11 17:28:57.094] [WARN] [DRC-Client-Thread] [transaction is 1018_40284768, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 492 [2026-05-11 17:28:57.096] [WARN] [DRC-Client-Thread] [transaction is 1018_40284768, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 493 [2026-05-11 17:28:57.097] [WARN] [DRC-Client-Thread] [transaction is 1018_40284768, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 494 [2026-05-11 17:28:57.099] [WARN] [DRC-Client-Thread] [transaction is 1018_40284768, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 495 [2026-05-11 17:28:57.100] [WARN] [DRC-Client-Thread] [transaction is 1018_40284768, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 496 [2026-05-11 17:28:57.101] [WARN] [DRC-Client-Thread] [transaction is 1018_40284768, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 497 [2026-05-11 17:28:57.102] [WARN] [DRC-Client-Thread] [transaction is 1018_40284768, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 498 [2026-05-11 17:28:57.103] [WARN] [DRC-Client-Thread] [transaction is 1018_40284768, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 499 [2026-05-11 17:28:57.104] [WARN] [DRC-Client-Thread] [transaction is 1018_40284768, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 500 [2026-05-11 17:28:57.106] [WARN] [DRC-Client-Thread] [transaction is 1018_40284768, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 501 [2026-05-11 17:28:57.107] [WARN] [DRC-Client-Thread] [transaction is 1018_40284768, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 502 [2026-05-11 17:28:57.108] [WARN] [DRC-Client-Thread] [transaction is 1018_40284768, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 503 [2026-05-11 17:28:57.109] [WARN] [DRC-Client-Thread] [transaction is 1018_40284768, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 504 [2026-05-11 17:28:57.111] [WARN] [DRC-Client-Thread] [transaction is 1018_40284768, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 505 [2026-05-11 17:28:57.112] [WARN] [DRC-Client-Thread] [transaction is 1018_40284768, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 506 [2026-05-11 17:28:57.113] [WARN] [DRC-Client-Thread] [transaction is 1018_40284768, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 507 [2026-05-11 17:28:57.115] [WARN] [DRC-Client-Thread] [transaction is 1018_40284768, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 508 [2026-05-11 17:28:57.117] [WARN] [DRC-Client-Thread] [transaction is 1018_40284768, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 509 [2026-05-11 17:28:57.119] [WARN] [DRC-Client-Thread] [transaction is 1018_40284768, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 510 [2026-05-11 17:28:57.121] [WARN] [DRC-Client-Thread] [transaction is 1018_40284768, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 511 [2026-05-11 17:28:57.122] [WARN] [DRC-Client-Thread] [transaction is 1018_40284768, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 512 [2026-05-11 17:28:58.509] [INFO] [forward_slot0-(ETLProcessor)-queue_slot1] [table name [t_amon_txn_qr_020] set for ddl [create /*+ parallel(4) */ index if not exists `IDX_AMONQR_ID_TXN` on `t_amon_txn_qr_020` (`ID_TXN` ASC) LOCAL]] 513 [2026-05-11 17:28:58.509] [WARN] [forward_slot0-(ETLProcessor)-queue_slot1] [DDLTransfer: ddl should be filtered, dbname:ate.ate, ddl: create /*+ parallel(4) */ index if not exists `IDX_AMONQR_ID_TXN` on `t_amon_txn_qr_020` (`ID_TXN` ASC) LOCAL] 514 [2026-05-11 17:28:58.509] [INFO] [forward_slot0-(ETLProcessor)-queue_slot1] [DDLTransfer: ddl create /*+ parallel(4) */ index if not exists `IDX_AMONQR_ID_TXN` on `t_amon_txn_qr_020` (`ID_TXN` ASC) LOCAL filter with map db null, with record db [ate.ate], table [null], parsed db[ate.ate], table[t_amon_txn_qr_020], dbToMap[ate.ate], tbToMap[t_amon_txn_qr_020]] 515 [2026-05-11 17:28:59.229] [INFO] [forward_slot0-(ETLProcessor)-queue_slot1] [table name [t_amon_txn_qr_031] set for ddl [create /*+ parallel(4) */ index if not exists `IDX_AMONQR_TERM_ID_TRACENO` on `t_amon_txn_qr_031` (`TERMINAL_ID` ASC, `TERM_TRACE_NO` ASC) LOCAL]] 516 [2026-05-11 17:28:59.229] [WARN] [forward_slot0-(ETLProcessor)-queue_slot1] [DDLTransfer: ddl should be filtered, dbname:ate.ate, ddl: create /*+ parallel(4) */ index if not exists `IDX_AMONQR_TERM_ID_TRACENO` on `t_amon_txn_qr_031` (`TERMINAL_ID` ASC, `TERM_TRACE_NO` ASC) LOCAL] 517 [2026-05-11 17:28:59.229] [INFO] [forward_slot0-(ETLProcessor)-queue_slot1] [DDLTransfer: ddl create /*+ parallel(4) */ index if not exists `IDX_AMONQR_TERM_ID_TRACENO` on `t_amon_txn_qr_031` (`TERMINAL_ID` ASC, `TERM_TRACE_NO` ASC) LOCAL filter with map db null, with record db [ate.ate], table [null], parsed db[ate.ate], table[t_amon_txn_qr_031], dbToMap[ate.ate], tbToMap[t_amon_txn_qr_031]] 518 [2026-05-11 17:29:01.028] [INFO] [forward_slot0-(ETLProcessor)-queue_slot1] [table name [t_amon_txn_qr_020] set for ddl [create /*+ parallel(4) */ index if not exists `IDX_AMONQR_MER_ID_EXTNO` on `t_amon_txn_qr_020` (`MERCHANT_ID` ASC, `EXT_TRACE_NO` ASC) LOCAL]] 519 [2026-05-11 17:29:01.029] [WARN] [forward_slot0-(ETLProcessor)-queue_slot1] [DDLTransfer: ddl should be filtered, dbname:ate.ate, ddl: create /*+ parallel(4) */ index if not exists `IDX_AMONQR_MER_ID_EXTNO` on `t_amon_txn_qr_020` (`MERCHANT_ID` ASC, `EXT_TRACE_NO` ASC) LOCAL] 520 [2026-05-11 17:29:01.029] [INFO] [forward_slot0-(ETLProcessor)-queue_slot1] [DDLTransfer: ddl create /*+ parallel(4) */ index if not exists `IDX_AMONQR_MER_ID_EXTNO` on `t_amon_txn_qr_020` (`MERCHANT_ID` ASC, `EXT_TRACE_NO` ASC) LOCAL filter with map db null, with record db [ate.ate], table [null], parsed db[ate.ate], table[t_amon_txn_qr_020], dbToMap[ate.ate], tbToMap[t_amon_txn_qr_020]] 521 [2026-05-11 17:29:01.189] [INFO] [forward_slot0-(ETLProcessor)-queue_slot1] [table name [t_amon_txn_qr_031] set for ddl [create /*+ parallel(4) */ index if not exists `IDX_AMONQR_TXN_TIME` on `t_amon_txn_qr_031` (`TXN_TIME` ASC) LOCAL]] 522 [2026-05-11 17:29:01.189] [WARN] [forward_slot0-(ETLProcessor)-queue_slot1] [DDLTransfer: ddl should be filtered, dbname:ate.ate, ddl: create /*+ parallel(4) */ index if not exists `IDX_AMONQR_TXN_TIME` on `t_amon_txn_qr_031` (`TXN_TIME` ASC) LOCAL] 523 [2026-05-11 17:29:01.189] [INFO] [forward_slot0-(ETLProcessor)-queue_slot1] [DDLTransfer: ddl create /*+ parallel(4) */ index if not exists `IDX_AMONQR_TXN_TIME` on `t_amon_txn_qr_031` (`TXN_TIME` ASC) LOCAL filter with map db null, with record db [ate.ate], table [null], parsed db[ate.ate], table[t_amon_txn_qr_031], dbToMap[ate.ate], tbToMap[t_amon_txn_qr_031]] 524 [2026-05-11 17:29:05.533] [INFO] [forward_slot0-(ETLProcessor)-queue_slot1] [table name [t_amon_txn_qr_020] set for ddl [create /*+ parallel(4) */ index if not exists `IDX_AMONQR_TERM_ID_TRACENO` on `t_amon_txn_qr_020` (`TERMINAL_ID` ASC, `TERM_TRACE_NO` ASC) LOCAL]] 525 [2026-05-11 17:29:05.533] [WARN] [forward_slot0-(ETLProcessor)-queue_slot1] [DDLTransfer: ddl should be filtered, dbname:ate.ate, ddl: create /*+ parallel(4) */ index if not exists `IDX_AMONQR_TERM_ID_TRACENO` on `t_amon_txn_qr_020` (`TERMINAL_ID` ASC, `TERM_TRACE_NO` ASC) LOCAL] 526 [2026-05-11 17:29:05.533] [INFO] [forward_slot0-(ETLProcessor)-queue_slot1] [DDLTransfer: ddl create /*+ parallel(4) */ index if not exists `IDX_AMONQR_TERM_ID_TRACENO` on `t_amon_txn_qr_020` (`TERMINAL_ID` ASC, `TERM_TRACE_NO` ASC) LOCAL filter with map db null, with record db [ate.ate], table [null], parsed db[ate.ate], table[t_amon_txn_qr_020], dbToMap[ate.ate], tbToMap[t_amon_txn_qr_020]] 527 [2026-05-11 17:29:08.052] [INFO] [forward_slot0-(ETLProcessor)-queue_slot1] [table name [t_amon_txn_qr_020] set for ddl [create /*+ parallel(4) */ index if not exists `IDX_AMONQR_TXN_TIME` on `t_amon_txn_qr_020` (`TXN_TIME` ASC) LOCAL]] 528 [2026-05-11 17:29:08.052] [WARN] [forward_slot0-(ETLProcessor)-queue_slot1] [DDLTransfer: ddl should be filtered, dbname:ate.ate, ddl: create /*+ parallel(4) */ index if not exists `IDX_AMONQR_TXN_TIME` on `t_amon_txn_qr_020` (`TXN_TIME` ASC) LOCAL] 529 [2026-05-11 17:29:08.052] [INFO] [forward_slot0-(ETLProcessor)-queue_slot1] [DDLTransfer: ddl create /*+ parallel(4) */ index if not exists `IDX_AMONQR_TXN_TIME` on `t_amon_txn_qr_020` (`TXN_TIME` ASC) LOCAL filter with map db null, with record db [ate.ate], table [null], parsed db[ate.ate], table[t_amon_txn_qr_020], dbToMap[ate.ate], tbToMap[t_amon_txn_qr_020]] 530 [2026-05-11 17:29:08.157] [WARN] [DRC-Client-Thread] [transaction is 1018_39573446, tableName is redis_collect_data, maxRecords is 64, cut it] 531 [2026-05-11 17:29:48.938] [INFO] [forward_slot0-(ETLProcessor)-queue_slot1] [table name [t_amon_txn_qr_027] set for ddl [create /*+ parallel(4) */ index if not exists `IDX_AMONQR_ID_TXN` on `t_amon_txn_qr_027` (`ID_TXN` ASC) LOCAL]] 532 [2026-05-11 17:29:48.938] [WARN] [forward_slot0-(ETLProcessor)-queue_slot1] [DDLTransfer: ddl should be filtered, dbname:ate.ate, ddl: create /*+ parallel(4) */ index if not exists `IDX_AMONQR_ID_TXN` on `t_amon_txn_qr_027` (`ID_TXN` ASC) LOCAL] 533 [2026-05-11 17:29:48.938] [INFO] [forward_slot0-(ETLProcessor)-queue_slot1] [DDLTransfer: ddl create /*+ parallel(4) */ index if not exists `IDX_AMONQR_ID_TXN` on `t_amon_txn_qr_027` (`ID_TXN` ASC) LOCAL filter with map db null, with record db [ate.ate], table [null], parsed db[ate.ate], table[t_amon_txn_qr_027], dbToMap[ate.ate], tbToMap[t_amon_txn_qr_027]] 534 [2026-05-11 17:29:52.536] [WARN] [DRC-Client-Thread] [transaction is 1018_40291341, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 535 [2026-05-11 17:29:52.537] [WARN] [DRC-Client-Thread] [transaction is 1018_40291341, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 536 [2026-05-11 17:29:52.538] [WARN] [DRC-Client-Thread] [transaction is 1018_40291341, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 537 [2026-05-11 17:29:52.539] [WARN] [DRC-Client-Thread] [transaction is 1018_40291341, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 538 [2026-05-11 17:29:52.540] [WARN] [DRC-Client-Thread] [transaction is 1018_40291341, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 539 [2026-05-11 17:29:52.542] [WARN] [DRC-Client-Thread] [transaction is 1018_40291341, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 540 [2026-05-11 17:29:52.543] [WARN] [DRC-Client-Thread] [transaction is 1018_40291341, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 541 [2026-05-11 17:29:52.544] [WARN] [DRC-Client-Thread] [transaction is 1018_40291341, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 542 [2026-05-11 17:29:52.544] [WARN] [DRC-Client-Thread] [transaction is 1018_40291341, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 543 [2026-05-11 17:29:52.545] [WARN] [DRC-Client-Thread] [transaction is 1018_40291341, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 544 [2026-05-11 17:29:52.546] [WARN] [DRC-Client-Thread] [transaction is 1018_40291341, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 545 [2026-05-11 17:29:52.547] [WARN] [DRC-Client-Thread] [transaction is 1018_40291341, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 546 [2026-05-11 17:29:52.547] [WARN] [DRC-Client-Thread] [transaction is 1018_40291341, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 547 [2026-05-11 17:29:52.549] [WARN] [DRC-Client-Thread] [transaction is 1018_40291341, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 548 [2026-05-11 17:29:52.550] [WARN] [DRC-Client-Thread] [transaction is 1018_40291341, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 549 [2026-05-11 17:29:52.551] [WARN] [DRC-Client-Thread] [transaction is 1018_40291341, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 550 [2026-05-11 17:29:52.553] [WARN] [DRC-Client-Thread] [transaction is 1018_40291341, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 551 [2026-05-11 17:29:52.553] [WARN] [DRC-Client-Thread] [transaction is 1018_40291341, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 552 [2026-05-11 17:29:52.554] [WARN] [DRC-Client-Thread] [transaction is 1018_40291341, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 553 [2026-05-11 17:29:52.555] [WARN] [DRC-Client-Thread] [transaction is 1018_40291341, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 554 [2026-05-11 17:29:52.556] [WARN] [DRC-Client-Thread] [transaction is 1018_40291341, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 555 [2026-05-11 17:29:52.557] [WARN] [DRC-Client-Thread] [transaction is 1018_40291341, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 556 [2026-05-11 17:29:52.558] [WARN] [DRC-Client-Thread] [transaction is 1018_40291341, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 557 [2026-05-11 17:29:52.559] [WARN] [DRC-Client-Thread] [transaction is 1018_40291341, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 558 [2026-05-11 17:29:52.560] [WARN] [DRC-Client-Thread] [transaction is 1018_40291341, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 559 [2026-05-11 17:29:52.561] [WARN] [DRC-Client-Thread] [transaction is 1018_40291341, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 560 [2026-05-11 17:29:52.562] [WARN] [DRC-Client-Thread] [transaction is 1018_40291341, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 561 [2026-05-11 17:29:52.562] [WARN] [DRC-Client-Thread] [transaction is 1018_40291341, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 562 [2026-05-11 17:29:52.564] [WARN] [DRC-Client-Thread] [transaction is 1018_40291341, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 563 [2026-05-11 17:29:52.565] [WARN] [DRC-Client-Thread] [transaction is 1018_40291341, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 564 [2026-05-11 17:29:52.566] [WARN] [DRC-Client-Thread] [transaction is 1018_40291341, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 565 [2026-05-11 17:29:52.745] [INFO] [DRC-Client-Thread] [notify consume: 0.02134423251589464 ms] 566 [2026-05-11 17:30:00.707] [WARN] [DRC-Client-Thread] [transaction is 1018_40294800, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 567 [2026-05-11 17:30:00.708] [WARN] [DRC-Client-Thread] [transaction is 1018_40294800, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 568 [2026-05-11 17:30:00.709] [WARN] [DRC-Client-Thread] [transaction is 1018_40294800, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 569 [2026-05-11 17:30:00.710] [WARN] [DRC-Client-Thread] [transaction is 1018_40294800, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 570 [2026-05-11 17:30:00.712] [WARN] [DRC-Client-Thread] [transaction is 1018_40294800, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 571 [2026-05-11 17:30:00.713] [WARN] [DRC-Client-Thread] [transaction is 1018_40294800, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 572 [2026-05-11 17:30:00.714] [WARN] [DRC-Client-Thread] [transaction is 1018_40294800, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 573 [2026-05-11 17:30:00.715] [WARN] [DRC-Client-Thread] [transaction is 1018_40294800, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 574 [2026-05-11 17:30:00.716] [WARN] [DRC-Client-Thread] [transaction is 1018_40294800, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 575 [2026-05-11 17:30:00.717] [WARN] [DRC-Client-Thread] [transaction is 1018_40294800, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 576 [2026-05-11 17:30:00.718] [WARN] [DRC-Client-Thread] [transaction is 1018_40294800, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 577 [2026-05-11 17:30:00.719] [WARN] [DRC-Client-Thread] [transaction is 1018_40294800, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 578 [2026-05-11 17:30:00.720] [WARN] [DRC-Client-Thread] [transaction is 1018_40294800, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 579 [2026-05-11 17:30:00.721] [WARN] [DRC-Client-Thread] [transaction is 1018_40294800, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 580 [2026-05-11 17:30:00.744] [WARN] [DRC-Client-Thread] [transaction is 1018_40294800, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 581 [2026-05-11 17:30:00.745] [WARN] [DRC-Client-Thread] [transaction is 1018_40294800, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 582 [2026-05-11 17:30:00.746] [WARN] [DRC-Client-Thread] [transaction is 1018_40294800, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 583 [2026-05-11 17:30:00.749] [WARN] [DRC-Client-Thread] [transaction is 1018_40294800, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 584 [2026-05-11 17:30:00.750] [WARN] [DRC-Client-Thread] [transaction is 1018_40294800, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 585 [2026-05-11 17:30:00.751] [WARN] [DRC-Client-Thread] [transaction is 1018_40294800, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 586 [2026-05-11 17:30:00.752] [WARN] [DRC-Client-Thread] [transaction is 1018_40294800, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 587 [2026-05-11 17:30:00.753] [WARN] [DRC-Client-Thread] [transaction is 1018_40294800, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 588 [2026-05-11 17:30:00.754] [WARN] [DRC-Client-Thread] [transaction is 1018_40294800, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 589 [2026-05-11 17:30:00.755] [WARN] [DRC-Client-Thread] [transaction is 1018_40294800, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 590 [2026-05-11 17:30:00.756] [WARN] [DRC-Client-Thread] [transaction is 1018_40294800, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 591 [2026-05-11 17:30:00.758] [WARN] [DRC-Client-Thread] [transaction is 1018_40294800, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 592 [2026-05-11 17:30:00.758] [WARN] [DRC-Client-Thread] [transaction is 1018_40294800, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 593 [2026-05-11 17:30:00.759] [WARN] [DRC-Client-Thread] [transaction is 1018_40294800, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 594 [2026-05-11 17:30:00.760] [WARN] [DRC-Client-Thread] [transaction is 1018_40294800, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 595 [2026-05-11 17:30:00.761] [WARN] [DRC-Client-Thread] [transaction is 1018_40294800, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 596 [2026-05-11 17:30:00.762] [WARN] [DRC-Client-Thread] [transaction is 1018_40294800, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 597 [2026-05-11 17:30:09.687] [WARN] [DRC-Client-Thread] [transaction is 1018_40297787, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 598 [2026-05-11 17:30:09.689] [WARN] [DRC-Client-Thread] [transaction is 1018_40297787, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 599 [2026-05-11 17:30:09.691] [WARN] [DRC-Client-Thread] [transaction is 1018_40297787, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 600 [2026-05-11 17:30:09.692] [WARN] [DRC-Client-Thread] [transaction is 1018_40297787, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 601 [2026-05-11 17:30:09.693] [WARN] [DRC-Client-Thread] [transaction is 1018_40297787, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 602 [2026-05-11 17:30:09.694] [WARN] [DRC-Client-Thread] [transaction is 1018_40297787, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 603 [2026-05-11 17:30:09.695] [WARN] [DRC-Client-Thread] [transaction is 1018_40297787, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 604 [2026-05-11 17:30:09.696] [WARN] [DRC-Client-Thread] [transaction is 1018_40297787, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 605 [2026-05-11 17:30:09.697] [WARN] [DRC-Client-Thread] [transaction is 1018_40297787, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 606 [2026-05-11 17:30:09.698] [WARN] [DRC-Client-Thread] [transaction is 1018_40297787, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 607 [2026-05-11 17:30:09.699] [WARN] [DRC-Client-Thread] [transaction is 1018_40297787, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 608 [2026-05-11 17:30:09.700] [WARN] [DRC-Client-Thread] [transaction is 1018_40297787, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 609 [2026-05-11 17:30:09.701] [WARN] [DRC-Client-Thread] [transaction is 1018_40297787, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 610 [2026-05-11 17:30:09.703] [WARN] [DRC-Client-Thread] [transaction is 1018_40297787, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 611 [2026-05-11 17:30:09.704] [WARN] [DRC-Client-Thread] [transaction is 1018_40297787, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 612 [2026-05-11 17:30:09.705] [WARN] [DRC-Client-Thread] [transaction is 1018_40297787, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 613 [2026-05-11 17:30:09.707] [WARN] [DRC-Client-Thread] [transaction is 1018_40297787, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 614 [2026-05-11 17:30:09.708] [WARN] [DRC-Client-Thread] [transaction is 1018_40297787, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 615 [2026-05-11 17:30:09.710] [WARN] [DRC-Client-Thread] [transaction is 1018_40297787, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 616 [2026-05-11 17:30:09.711] [WARN] [DRC-Client-Thread] [transaction is 1018_40297787, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 617 [2026-05-11 17:30:09.713] [WARN] [DRC-Client-Thread] [transaction is 1018_40297787, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 618 [2026-05-11 17:30:09.715] [WARN] [DRC-Client-Thread] [transaction is 1018_40297787, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 619 [2026-05-11 17:30:09.716] [WARN] [DRC-Client-Thread] [transaction is 1018_40297787, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 620 [2026-05-11 17:30:09.718] [WARN] [DRC-Client-Thread] [transaction is 1018_40297787, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 621 [2026-05-11 17:30:09.720] [WARN] [DRC-Client-Thread] [transaction is 1018_40297787, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 622 [2026-05-11 17:30:09.722] [WARN] [DRC-Client-Thread] [transaction is 1018_40297787, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 623 [2026-05-11 17:30:09.723] [WARN] [DRC-Client-Thread] [transaction is 1018_40297787, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 624 [2026-05-11 17:30:09.725] [WARN] [DRC-Client-Thread] [transaction is 1018_40297787, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 625 [2026-05-11 17:30:09.726] [WARN] [DRC-Client-Thread] [transaction is 1018_40297787, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 626 [2026-05-11 17:30:09.727] [WARN] [DRC-Client-Thread] [transaction is 1018_40297787, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 627 [2026-05-11 17:30:09.729] [WARN] [DRC-Client-Thread] [transaction is 1018_40297787, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 628 [2026-05-11 17:30:14.851] [INFO] [forward_slot0-(ETLProcessor)-queue_slot1] [table name [t_amon_txn_qr_027] set for ddl [create /*+ parallel(4) */ index if not exists `IDX_AMONQR_MER_ID_EXTNO` on `t_amon_txn_qr_027` (`MERCHANT_ID` ASC, `EXT_TRACE_NO` ASC) LOCAL]] 629 [2026-05-11 17:30:14.852] [WARN] [forward_slot0-(ETLProcessor)-queue_slot1] [DDLTransfer: ddl should be filtered, dbname:ate.ate, ddl: create /*+ parallel(4) */ index if not exists `IDX_AMONQR_MER_ID_EXTNO` on `t_amon_txn_qr_027` (`MERCHANT_ID` ASC, `EXT_TRACE_NO` ASC) LOCAL] 630 [2026-05-11 17:30:14.852] [INFO] [forward_slot0-(ETLProcessor)-queue_slot1] [DDLTransfer: ddl create /*+ parallel(4) */ index if not exists `IDX_AMONQR_MER_ID_EXTNO` on `t_amon_txn_qr_027` (`MERCHANT_ID` ASC, `EXT_TRACE_NO` ASC) LOCAL filter with map db null, with record db [ate.ate], table [null], parsed db[ate.ate], table[t_amon_txn_qr_027], dbToMap[ate.ate], tbToMap[t_amon_txn_qr_027]] 631 [2026-05-11 17:30:14.905] [WARN] [DRC-Client-Thread] [transaction is 1018_40300702, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 632 [2026-05-11 17:30:14.906] [WARN] [DRC-Client-Thread] [transaction is 1018_40300702, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 633 [2026-05-11 17:30:14.907] [WARN] [DRC-Client-Thread] [transaction is 1018_40300702, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 634 [2026-05-11 17:30:14.909] [WARN] [DRC-Client-Thread] [transaction is 1018_40300702, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 635 [2026-05-11 17:30:14.911] [WARN] [DRC-Client-Thread] [transaction is 1018_40300702, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 636 [2026-05-11 17:30:14.912] [WARN] [DRC-Client-Thread] [transaction is 1018_40300702, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 637 [2026-05-11 17:30:14.913] [WARN] [DRC-Client-Thread] [transaction is 1018_40300702, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 638 [2026-05-11 17:30:14.914] [WARN] [DRC-Client-Thread] [transaction is 1018_40300702, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 639 [2026-05-11 17:30:14.915] [WARN] [DRC-Client-Thread] [transaction is 1018_40300702, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 640 [2026-05-11 17:30:14.916] [WARN] [DRC-Client-Thread] [transaction is 1018_40300702, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 641 [2026-05-11 17:30:14.918] [WARN] [DRC-Client-Thread] [transaction is 1018_40300702, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 642 [2026-05-11 17:30:14.919] [WARN] [DRC-Client-Thread] [transaction is 1018_40300702, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 643 [2026-05-11 17:30:14.920] [WARN] [DRC-Client-Thread] [transaction is 1018_40300702, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 644 [2026-05-11 17:30:14.921] [WARN] [DRC-Client-Thread] [transaction is 1018_40300702, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 645 [2026-05-11 17:30:14.922] [WARN] [DRC-Client-Thread] [transaction is 1018_40300702, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 646 [2026-05-11 17:30:14.923] [WARN] [DRC-Client-Thread] [transaction is 1018_40300702, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 647 [2026-05-11 17:30:14.925] [WARN] [DRC-Client-Thread] [transaction is 1018_40300702, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 648 [2026-05-11 17:30:14.926] [WARN] [DRC-Client-Thread] [transaction is 1018_40300702, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 649 [2026-05-11 17:30:14.927] [WARN] [DRC-Client-Thread] [transaction is 1018_40300702, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 650 [2026-05-11 17:30:14.928] [WARN] [DRC-Client-Thread] [transaction is 1018_40300702, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 651 [2026-05-11 17:30:14.929] [WARN] [DRC-Client-Thread] [transaction is 1018_40300702, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 652 [2026-05-11 17:30:14.930] [WARN] [DRC-Client-Thread] [transaction is 1018_40300702, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 653 [2026-05-11 17:30:14.931] [WARN] [DRC-Client-Thread] [transaction is 1018_40300702, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 654 [2026-05-11 17:30:14.933] [WARN] [DRC-Client-Thread] [transaction is 1018_40300702, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 655 [2026-05-11 17:30:14.934] [WARN] [DRC-Client-Thread] [transaction is 1018_40300702, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 656 [2026-05-11 17:30:14.934] [WARN] [DRC-Client-Thread] [transaction is 1018_40300702, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 657 [2026-05-11 17:30:14.935] [WARN] [DRC-Client-Thread] [transaction is 1018_40300702, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 658 [2026-05-11 17:30:14.936] [WARN] [DRC-Client-Thread] [transaction is 1018_40300702, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 659 [2026-05-11 17:30:16.923] [INFO] [timerTaskScheduler] [ 660 sinkTaskProcesslist 661 sinkTask-31==>DML[meta[monitor-stat_mq_queue_info_history,1778485159,INSERT,1778482891]post[Struct{id(INT64)=5226402875,tibco_alias(VAR_CHAR_STRING)=jq_cps_t,name(VAR_CHAR_STRING)=bgw.mdp.NewResponseQueue.ZGWL0501,url(VAR_CHAR_STRING)=tcp://tibco-cps-t01.99bill.com:7222,type(INT32)=1,static_tag(INT8)=0,receiver_count(INT32)=320,pending_msg_count(INT64)=0,pending_msg_size(INT64)=0,delivered_msg_count(INT64)=0,in_msg_rate(INT64)=0,in_bytes_rate(INT64)=0,in_total_bytes(INT64)=828304105,in_total_msgs(INT64)=188371,out_msg_rate(INT64)=0,out_bytes_rate(INT64)=0,out_total_bytes(INT64)=828304105,out_total_msgs(INT64)=188371,collect_time(DATETIME)=2026-05-11 15:39:00,create_time(DATETIME)=2026-05-11 15:39:18}]]... 662 ] 663 [2026-05-11 17:30:32.735] [INFO] [forward_slot0-(ETLProcessor)-queue_slot1] [table name [t_amon_txn_qr_027] set for ddl [create /*+ parallel(4) */ index if not exists `IDX_AMONQR_TERM_ID_TRACENO` on `t_amon_txn_qr_027` (`TERMINAL_ID` ASC, `TERM_TRACE_NO` ASC) LOCAL]] 664 [2026-05-11 17:30:32.735] [WARN] [forward_slot0-(ETLProcessor)-queue_slot1] [DDLTransfer: ddl should be filtered, dbname:ate.ate, ddl: create /*+ parallel(4) */ index if not exists `IDX_AMONQR_TERM_ID_TRACENO` on `t_amon_txn_qr_027` (`TERMINAL_ID` ASC, `TERM_TRACE_NO` ASC) LOCAL] 665 [2026-05-11 17:30:32.735] [INFO] [forward_slot0-(ETLProcessor)-queue_slot1] [DDLTransfer: ddl create /*+ parallel(4) */ index if not exists `IDX_AMONQR_TERM_ID_TRACENO` on `t_amon_txn_qr_027` (`TERMINAL_ID` ASC, `TERM_TRACE_NO` ASC) LOCAL filter with map db null, with record db [ate.ate], table [null], parsed db[ate.ate], table[t_amon_txn_qr_027], dbToMap[ate.ate], tbToMap[t_amon_txn_qr_027]] 666 [2026-05-11 17:30:52.310] [INFO] [forward_slot0-(ETLProcessor)-queue_slot1] [table name [t_amon_txn_qr_027] set for ddl [create /*+ parallel(4) */ index if not exists `IDX_AMONQR_TXN_TIME` on `t_amon_txn_qr_027` (`TXN_TIME` ASC) LOCAL]] 667 [2026-05-11 17:30:52.310] [WARN] [forward_slot0-(ETLProcessor)-queue_slot1] [DDLTransfer: ddl should be filtered, dbname:ate.ate, ddl: create /*+ parallel(4) */ index if not exists `IDX_AMONQR_TXN_TIME` on `t_amon_txn_qr_027` (`TXN_TIME` ASC) LOCAL] 668 [2026-05-11 17:30:52.310] [INFO] [forward_slot0-(ETLProcessor)-queue_slot1] [DDLTransfer: ddl create /*+ parallel(4) */ index if not exists `IDX_AMONQR_TXN_TIME` on `t_amon_txn_qr_027` (`TXN_TIME` ASC) LOCAL filter with map db null, with record db [ate.ate], table [null], parsed db[ate.ate], table[t_amon_txn_qr_027], dbToMap[ate.ate], tbToMap[t_amon_txn_qr_027]] 669 [2026-05-11 17:30:52.774] [INFO] [DRC-Client-Thread] [notify consume: 0.022471439052510218 ms] 670 [2026-05-11 17:31:06.091] [WARN] [DRC-Client-Thread] [transaction is 1018_40307195, tableName is stat_sms_delivery_info_history, maxRecords is 64, cut it] 671 [2026-05-11 17:31:06.092] [WARN] [DRC-Client-Thread] [transaction is 1018_40307195, tableName is stat_sms_delivery_info_history, maxRecords is 64, cut it] 672 [2026-05-11 17:31:06.093] [WARN] [DRC-Client-Thread] [transaction is 1018_40307195, tableName is stat_sms_delivery_info_history, maxRecords is 64, cut it] 673 [2026-05-11 17:31:06.094] [WARN] [DRC-Client-Thread] [transaction is 1018_40307195, tableName is stat_sms_delivery_info_history, maxRecords is 64, cut it] 674 [2026-05-11 17:31:06.094] [WARN] [DRC-Client-Thread] [transaction is 1018_40307195, tableName is stat_sms_delivery_info_history, maxRecords is 64, cut it] 675 [2026-05-11 17:31:06.095] [WARN] [DRC-Client-Thread] [transaction is 1018_40307195, tableName is stat_sms_delivery_info_history, maxRecords is 64, cut it] 676 [2026-05-11 17:31:06.096] [WARN] [DRC-Client-Thread] [transaction is 1018_40307195, tableName is stat_sms_delivery_info_history, maxRecords is 64, cut it] 677 [2026-05-11 17:31:06.096] [WARN] [DRC-Client-Thread] [transaction is 1018_40307195, tableName is stat_sms_delivery_info_history, maxRecords is 64, cut it] 678 [2026-05-11 17:31:06.097] [WARN] [DRC-Client-Thread] [transaction is 1018_40307195, tableName is stat_sms_delivery_info_history, maxRecords is 64, cut it] 679 [2026-05-11 17:31:06.097] [WARN] [DRC-Client-Thread] [transaction is 1018_40307195, tableName is stat_sms_delivery_info_history, maxRecords is 64, cut it] 680 [2026-05-11 17:31:06.126] [WARN] [DRC-Client-Thread] [transaction is 1018_40307195, tableName is stat_sms_delivery_info_history, maxRecords is 64, cut it] 681 [2026-05-11 17:31:06.126] [WARN] [DRC-Client-Thread] [transaction is 1018_40307195, tableName is stat_sms_delivery_info_history, maxRecords is 64, cut it] 682 [2026-05-11 17:31:08.192] [WARN] [DRC-Client-Thread] [transaction is 1018_40307181, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 683 [2026-05-11 17:31:08.193] [WARN] [DRC-Client-Thread] [transaction is 1018_40307181, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 684 [2026-05-11 17:31:08.194] [WARN] [DRC-Client-Thread] [transaction is 1018_40307181, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 685 [2026-05-11 17:31:08.195] [WARN] [DRC-Client-Thread] [transaction is 1018_40307181, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 686 [2026-05-11 17:31:08.196] [WARN] [DRC-Client-Thread] [transaction is 1018_40307181, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 687 [2026-05-11 17:31:08.198] [WARN] [DRC-Client-Thread] [transaction is 1018_40307181, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 688 [2026-05-11 17:31:08.199] [WARN] [DRC-Client-Thread] [transaction is 1018_40307181, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 689 [2026-05-11 17:31:08.200] [WARN] [DRC-Client-Thread] [transaction is 1018_40307181, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 690 [2026-05-11 17:31:08.201] [WARN] [DRC-Client-Thread] [transaction is 1018_40307181, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 691 [2026-05-11 17:31:08.202] [WARN] [DRC-Client-Thread] [transaction is 1018_40307181, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 692 [2026-05-11 17:31:08.204] [WARN] [DRC-Client-Thread] [transaction is 1018_40307181, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 693 [2026-05-11 17:31:08.205] [WARN] [DRC-Client-Thread] [transaction is 1018_40307181, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 694 [2026-05-11 17:31:08.206] [WARN] [DRC-Client-Thread] [transaction is 1018_40307181, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 695 [2026-05-11 17:31:08.207] [WARN] [DRC-Client-Thread] [transaction is 1018_40307181, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 696 [2026-05-11 17:31:08.207] [WARN] [DRC-Client-Thread] [transaction is 1018_40307181, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 697 [2026-05-11 17:31:08.208] [WARN] [DRC-Client-Thread] [transaction is 1018_40307181, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 698 [2026-05-11 17:31:08.209] [WARN] [DRC-Client-Thread] [transaction is 1018_40307181, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 699 [2026-05-11 17:31:08.210] [WARN] [DRC-Client-Thread] [transaction is 1018_40307181, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 700 [2026-05-11 17:31:08.211] [WARN] [DRC-Client-Thread] [transaction is 1018_40307181, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 701 [2026-05-11 17:31:08.211] [WARN] [DRC-Client-Thread] [transaction is 1018_40307181, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 702 [2026-05-11 17:31:08.212] [WARN] [DRC-Client-Thread] [transaction is 1018_40307181, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 703 [2026-05-11 17:31:08.213] [WARN] [DRC-Client-Thread] [transaction is 1018_40307181, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 704 [2026-05-11 17:31:08.214] [WARN] [DRC-Client-Thread] [transaction is 1018_40307181, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 705 [2026-05-11 17:31:08.214] [WARN] [DRC-Client-Thread] [transaction is 1018_40307181, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 706 [2026-05-11 17:31:08.215] [WARN] [DRC-Client-Thread] [transaction is 1018_40307181, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 707 [2026-05-11 17:31:08.216] [WARN] [DRC-Client-Thread] [transaction is 1018_40307181, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 708 [2026-05-11 17:31:08.217] [WARN] [DRC-Client-Thread] [transaction is 1018_40307181, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 709 [2026-05-11 17:31:08.217] [WARN] [DRC-Client-Thread] [transaction is 1018_40307181, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 710 [2026-05-11 17:31:08.218] [WARN] [DRC-Client-Thread] [transaction is 1018_40307181, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 711 [2026-05-11 17:31:08.219] [WARN] [DRC-Client-Thread] [transaction is 1018_40307181, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 712 [2026-05-11 17:31:08.220] [WARN] [DRC-Client-Thread] [transaction is 1018_40307181, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 713 [2026-05-11 17:31:09.294] [INFO] [forward_slot0-(ETLProcessor)-queue_slot1] [table name [t_amon_txn_qr_033] set for ddl [create /*+ parallel(4) */ index if not exists `IDX_AMONQR_ID_TXN` on `t_amon_txn_qr_033` (`ID_TXN` ASC) LOCAL]] 714 [2026-05-11 17:31:09.294] [WARN] [forward_slot0-(ETLProcessor)-queue_slot1] [DDLTransfer: ddl should be filtered, dbname:ate.ate, ddl: create /*+ parallel(4) */ index if not exists `IDX_AMONQR_ID_TXN` on `t_amon_txn_qr_033` (`ID_TXN` ASC) LOCAL] 715 [2026-05-11 17:31:09.294] [INFO] [forward_slot0-(ETLProcessor)-queue_slot1] [DDLTransfer: ddl create /*+ parallel(4) */ index if not exists `IDX_AMONQR_ID_TXN` on `t_amon_txn_qr_033` (`ID_TXN` ASC) LOCAL filter with map db null, with record db [ate.ate], table [null], parsed db[ate.ate], table[t_amon_txn_qr_033], dbToMap[ate.ate], tbToMap[t_amon_txn_qr_033]] 716 [2026-05-11 17:31:11.670] [WARN] [DRC-Client-Thread] [transaction is 1018_40309450, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 717 [2026-05-11 17:31:11.671] [WARN] [DRC-Client-Thread] [transaction is 1018_40309450, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 718 [2026-05-11 17:31:11.674] [WARN] [DRC-Client-Thread] [transaction is 1018_40309450, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 719 [2026-05-11 17:31:11.675] [WARN] [DRC-Client-Thread] [transaction is 1018_40309450, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 720 [2026-05-11 17:31:11.676] [WARN] [DRC-Client-Thread] [transaction is 1018_40309450, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 721 [2026-05-11 17:31:11.677] [WARN] [DRC-Client-Thread] [transaction is 1018_40309450, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 722 [2026-05-11 17:31:11.678] [WARN] [DRC-Client-Thread] [transaction is 1018_40309450, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 723 [2026-05-11 17:31:11.680] [WARN] [DRC-Client-Thread] [transaction is 1018_40309450, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 724 [2026-05-11 17:31:11.681] [WARN] [DRC-Client-Thread] [transaction is 1018_40309450, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 725 [2026-05-11 17:31:11.682] [WARN] [DRC-Client-Thread] [transaction is 1018_40309450, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 726 [2026-05-11 17:31:11.683] [WARN] [DRC-Client-Thread] [transaction is 1018_40309450, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 727 [2026-05-11 17:31:11.683] [WARN] [DRC-Client-Thread] [transaction is 1018_40309450, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 728 [2026-05-11 17:31:11.684] [WARN] [DRC-Client-Thread] [transaction is 1018_40309450, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 729 [2026-05-11 17:31:11.685] [WARN] [DRC-Client-Thread] [transaction is 1018_40309450, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 730 [2026-05-11 17:31:11.686] [WARN] [DRC-Client-Thread] [transaction is 1018_40309450, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 731 [2026-05-11 17:31:11.687] [WARN] [DRC-Client-Thread] [transaction is 1018_40309450, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 732 [2026-05-11 17:31:11.687] [WARN] [DRC-Client-Thread] [transaction is 1018_40309450, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 733 [2026-05-11 17:31:11.688] [WARN] [DRC-Client-Thread] [transaction is 1018_40309450, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 734 [2026-05-11 17:31:11.689] [WARN] [DRC-Client-Thread] [transaction is 1018_40309450, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 735 [2026-05-11 17:31:11.690] [WARN] [DRC-Client-Thread] [transaction is 1018_40309450, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 736 [2026-05-11 17:31:11.690] [WARN] [DRC-Client-Thread] [transaction is 1018_40309450, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 737 [2026-05-11 17:31:11.691] [WARN] [DRC-Client-Thread] [transaction is 1018_40309450, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 738 [2026-05-11 17:31:11.692] [WARN] [DRC-Client-Thread] [transaction is 1018_40309450, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 739 [2026-05-11 17:31:11.693] [WARN] [DRC-Client-Thread] [transaction is 1018_40309450, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 740 [2026-05-11 17:31:11.693] [WARN] [DRC-Client-Thread] [transaction is 1018_40309450, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 741 [2026-05-11 17:31:11.694] [WARN] [DRC-Client-Thread] [transaction is 1018_40309450, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 742 [2026-05-11 17:31:11.695] [WARN] [DRC-Client-Thread] [transaction is 1018_40309450, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 743 [2026-05-11 17:31:11.696] [WARN] [DRC-Client-Thread] [transaction is 1018_40309450, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 744 [2026-05-11 17:31:11.696] [WARN] [DRC-Client-Thread] [transaction is 1018_40309450, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 745 [2026-05-11 17:31:11.697] [WARN] [DRC-Client-Thread] [transaction is 1018_40309450, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 746 [2026-05-11 17:31:11.698] [WARN] [DRC-Client-Thread] [transaction is 1018_40309450, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 747 [2026-05-11 17:31:16.925] [INFO] [timerTaskScheduler] [ 748 sinkTaskProcesslist 749 sinkTask-5==>DML[meta[monitor-stat_mq_queue_info_history,1778485211,INSERT,1778482891]post[Struct{id(INT64)=5226408502,tibco_alias(VAR_CHAR_STRING)=jq_seashell,name(VAR_CHAR_STRING)=notify.app.ebpp.eri.creditCardPayInnerApi,url(VAR_CHAR_STRING)=tcp://tibco-seashell01.99bill.com:7222,type(INT32)=1,static_tag(INT8)=1,receiver_count(INT32)=0,pending_msg_count(INT64)=0,pending_msg_size(INT64)=0,delivered_msg_count(INT64)=0,in_msg_rate(INT64)=0,in_bytes_rate(INT64)=0,in_total_bytes(INT64)=0,in_total_msgs(INT64)=0,out_msg_rate(INT64)=0,out_bytes_rate(INT64)=0,out_total_bytes(INT64)=0,out_total_msgs(INT64)=0,collect_time(DATETIME)=2026-05-11 15:40:00,create_time(DATETIME)=2026-05-11 15:40:11}]]... 750 sinkTask-14==>DML[meta[monitor-stat_mq_queue_info_history,1778485211,INSERT,1778482891]post[Struct{id(INT64)=5226408495,tibco_alias(VAR_CHAR_STRING)=jq_cpd_x_02,name(VAR_CHAR_STRING)=mas.mdp.asyn.AcceptCapaticyRequestQueue,url(VAR_CHAR_STRING)=tcp://tibco-cpd02-cloud02.99bill.com:7222,type(INT32)=1,static_tag(INT8)=1,receiver_count(INT32)=0,pending_msg_count(INT64)=0,pending_msg_size(INT64)=0,delivered_msg_count(INT64)=0,in_msg_rate(INT64)=0,in_bytes_rate(INT64)=0,in_total_bytes(INT64)=0,in_total_msgs(INT64)=0,out_msg_rate(INT64)=0,out_bytes_rate(INT64)=0,out_total_bytes(INT64)=0,out_total_msgs(INT64)=0,collect_time(DATETIME)=2026-05-11 15:40:00,create_time(DATETIME)=2026-05-11 15:40:11}]]... 751 sinkTask-18==>DML[meta[monitor-stat_mq_queue_info_history,1778485211,INSERT,1778482891]post[Struct{id(INT64)=5226408501,tibco_alias(VAR_CHAR_STRING)=jq_cpd_x_02,name(VAR_CHAR_STRING)=mas.mnp.TxnResultReceiveQueue,url(VAR_CHAR_STRING)=tcp://tibco-cpd02-cloud02.99bill.com:7222,type(INT32)=1,static_tag(INT8)=1,receiver_count(INT32)=0,pending_msg_count(INT64)=0,pending_msg_size(INT64)=0,delivered_msg_count(INT64)=0,in_msg_rate(INT64)=0,in_bytes_rate(INT64)=0,in_total_bytes(INT64)=0,in_total_msgs(INT64)=0,out_msg_rate(INT64)=0,out_bytes_rate(INT64)=0,out_total_bytes(INT64)=0,out_total_msgs(INT64)=0,collect_time(DATETIME)=2026-05-11 15:40:00,create_time(DATETIME)=2026-05-11 15:40:11}]]... 752 sinkTask-26==>DML[meta[monitor-stat_mq_queue_info,1778485211,UPDATE,1778482891]prev[Struct{id(INT32)=3992,tibco_alias(VAR_CHAR_STRING)=jq_cps_t,url(VAR_CHAR_STRING)=tcp://tibco-cps-t01.99bill.com:7222,name(VAR_CHAR_STRING)=bgw.mdp.NewRequestQueue.03051142,type(INT32)=1,static_tag(INT8)=1,product_id(VAR_CHAR_STRING)=DEFAULT,description(VAR_CHAR_STRING)=,alarm_settings(VAR_CHAR_STRING)=,on_tag(INT8)=1,receiver_count(INT32)=0,pending_msg_count(INT64)=0,pending_msg_size(INT64)=0,delivered_msg_count(INT64)=0,in_msg_rate(INT64)=0,in_bytes_rate(INT64)=0,in_total_bytes(INT64)=0,in_total_msgs(INT64)=0,out_msg_rate(INT64)=0,out_bytes_rate(INT64)=0,out_total_bytes(INT64)=0,out_total_msgs(INT64)=0,collect_time(DATETIME)=2026-05-11 15:39:00,create_time(DATETIME)=2023-08-23 13:30:01,update_time(DATETIME)=2023-08-23 13:30:01}] post[Struct{id(INT32)=3992,tibco_alias(VAR_CHAR_STRING)=jq_cps_t,url(VAR_CHAR_STRING)=tcp://tibco-cps-t01.99bill.com:7222,name(VAR_CHAR_STRING)=bgw.mdp.NewRequestQueue.03051142,type(INT32)=1,static_tag(INT8)=1,product_id(VAR_CHAR_STRING)=DEFAULT,description(VAR_CHAR_STRING)=,alarm_settings(VAR_CHAR_STRING)=,on_tag(INT8)=1,receiver_count(INT32)=0,pending_msg_count(INT64)=0,pending_msg_size(INT64)=0,delivered_msg_count(INT64)=0,in_msg_rate(INT64)=0,in_bytes_rate(INT64)=0,in_total_bytes(INT64)=0,in_total_msgs(INT64)=0,out_msg_rate(INT64)=0,out_bytes_rate(INT64)=0,out_total_bytes(INT64)=0,out_total_msgs(INT64)=0,collect_time(DATETIME)=2026-05-11 15:40:00,create_time(DATETIME)=2023-08-23 13:30:01,update_time(DATETIME)=2023-08-23 13:30:01}]]... 753 sinkTask-32==>DML[meta[monitor-mq_collect_data,1778485211,INSERT,1778482891]post[Struct{id(INT64)=259886619,collect_time(DATETIME)=2026-05-11 15:40:12,product_id(VAR_CHAR_STRING)=INF,mq_name(VAR_CHAR_STRING)=notify.if.monitor.fi.srvpoint.responsequeue,pending_msg_cnt(INT64)=0,pending_msg_size(INT64)=0,max_msg_cnt(INT64)=0,max_msg_size(INT64)=52428800,consumer_count(INT64)=0,intransit_message_count(INT64)=0,delivered_message_count(INT64)=0,max_redelivery(INT32)=0,reciever_count(INT32)=0,is_exclusive(INT8)=0,overflow_policy(VAR_CHAR_STRING)=OVERFLOW_DEFAULT,prefetch(INT32)=5,consumer_hosts(VAR_CHAR_STRING)=,in_byte_rate(DOUBLE)=0,in_message_rate(DOUBLE)=0,in_total_bytes(INT64)=0,in_total_messages(INT64)=0,out_byte_rate(DOUBLE)=0,out_message_rate(DOUBLE)=0,out_total_bytes(INT64)=0,out_total_messages(INT64)=0,mq_server_name(VAR_CHAR_STRING)=tcp://tibco-quartz01.99bill.com:7222,tcp://tibco-quartz02.99bill.com:7222}]]... 754 sinkTask-34==>DML[meta[monitor-rrd_collect_data,1778485211,INSERT,1778482891]post[Struct{id(INT32)=217254834,product_id(VAR_CHAR_STRING)=FI,group_id(VAR_CHAR_STRING)=2022092301,picture_id(VAR_CHAR_STRING)=2022092301,value(INT32)=100,metric(VAR_CHAR_STRING)=RADIO,time(DATETIME)=2026-05-11 15:35:00,title(VAR_CHAR_STRING)=重要商户-航空公司-OTA平台5分钟消费交易成功率,create_time(DATETIME)=2026-05-11 15:40:11,monitor_model(INT32)=0}]]... 755 sinkTask-47==>DML[meta[monitor-stat_mq_queue_info_history,1778485211,INSERT,1778482891]post[Struct{id(INT64)=5226408504,tibco_alias(VAR_CHAR_STRING)=jq_cpd_x_cloud,name(VAR_CHAR_STRING)=bgw.mdp.NewRequestQueue.YLZX0100,url(VAR_CHAR_STRING)=tcp://tibco-cpd-cloud01.99bill.com:7222,type(INT32)=1,static_tag(INT8)=1,receiver_count(INT32)=0,pending_msg_count(INT64)=0,pending_msg_size(INT64)=0,delivered_msg_count(INT64)=0,in_msg_rate(INT64)=0,in_bytes_rate(INT64)=0,in_total_bytes(INT64)=0,in_total_msgs(INT64)=0,out_msg_rate(INT64)=0,out_bytes_rate(INT64)=0,out_total_bytes(INT64)=0,out_total_msgs(INT64)=0,collect_time(DATETIME)=2026-05-11 15:40:00,create_time(DATETIME)=2026-05-11 15:40:11}]]... 756 sinkTask-55==>DML[meta[monitor-stat_mq_queue_info,1778485211,UPDATE,1778482891]prev[Struct{id(INT32)=3993,tibco_alias(VAR_CHAR_STRING)=jq_cps_t,url(VAR_CHAR_STRING)=tcp://tibco-cps-t01.99bill.com:7222,name(VAR_CHAR_STRING)=bgw.mdp.NewRequestQueue.03052100,type(INT32)=1,static_tag(INT8)=1,product_id(VAR_CHAR_STRING)=DEFAULT,description(VAR_CHAR_STRING)=,alarm_settings(VAR_CHAR_STRING)=,on_tag(INT8)=1,receiver_count(INT32)=0,pending_msg_count(INT64)=0,pending_msg_size(INT64)=0,delivered_msg_count(INT64)=0,in_msg_rate(INT64)=0,in_bytes_rate(INT64)=0,in_total_bytes(INT64)=0,in_total_msgs(INT64)=0,out_msg_rate(INT64)=0,out_bytes_rate(INT64)=0,out_total_bytes(INT64)=0,out_total_msgs(INT64)=0,collect_time(DATETIME)=2026-05-11 15:39:00,create_time(DATETIME)=2023-08-23 13:30:01,update_time(DATETIME)=2023-08-23 13:30:01}] post[Struct{id(INT32)=3993,tibco_alias(VAR_CHAR_STRING)=jq_cps_t,url(VAR_CHAR_STRING)=tcp://tibco-cps-t01.99bill.com:7222,name(VAR_CHAR_STRING)=bgw.mdp.NewRequestQueue.03052100,type(INT32)=1,static_tag(INT8)=1,product_id(VAR_CHAR_STRING)=DEFAULT,description(VAR_CHAR_STRING)=,alarm_settings(VAR_CHAR_STRING)=,on_tag(INT8)=1,receiver_count(INT32)=0,pending_msg_count(INT64)=0,pending_msg_size(INT64)=0,delivered_msg_count(INT64)=0,in_msg_rate(INT64)=0,in_bytes_rate(INT64)=0,in_total_bytes(INT64)=0,in_total_msgs(INT64)=0,out_msg_rate(INT64)=0,out_bytes_rate(INT64)=0,out_total_bytes(INT64)=0,out_total_msgs(INT64)=0,collect_time(DATETIME)=2026-05-11 15:40:00,create_time(DATETIME)=2023-08-23 13:30:01,update_time(DATETIME)=2023-08-23 13:30:01}]]... 757 sinkTask-59==>DML[meta[monitor-stat_mq_queue_info_history,1778485211,INSERT,1778482891]post[Struct{id(INT64)=5226408506,tibco_alias(VAR_CHAR_STRING)=jq_seashell,name(VAR_CHAR_STRING)=notify.app.ebpp.eto.channelProcessNotifyHandle,url(VAR_CHAR_STRING)=tcp://tibco-seashell01.99bill.com:7222,type(INT32)=1,static_tag(INT8)=1,receiver_count(INT32)=0,pending_msg_count(INT64)=0,pending_msg_size(INT64)=0,delivered_msg_count(INT64)=0,in_msg_rate(INT64)=0,in_bytes_rate(INT64)=0,in_total_bytes(INT64)=0,in_total_msgs(INT64)=0,out_msg_rate(INT64)=0,out_bytes_rate(INT64)=0,out_total_bytes(INT64)=0,out_total_msgs(INT64)=0,collect_time(DATETIME)=2026-05-11 15:40:00,create_time(DATETIME)=2026-05-11 15:40:11}]]... 758 sinkTask-61==>DML[meta[monitor-stat_mq_queue_info_history,1778485211,INSERT,1778482891]post[Struct{id(INT64)=5226408503,tibco_alias(VAR_CHAR_STRING)=jq_cpd_x_02,name(VAR_CHAR_STRING)=mbp.mdp.RequestQueue,url(VAR_CHAR_STRING)=tcp://tibco-cpd02-cloud02.99bill.com:7222,type(INT32)=1,static_tag(INT8)=1,receiver_count(INT32)=0,pending_msg_count(INT64)=0,pending_msg_size(INT64)=0,delivered_msg_count(INT64)=0,in_msg_rate(INT64)=0,in_bytes_rate(INT64)=0,in_total_bytes(INT64)=0,in_total_msgs(INT64)=0,out_msg_rate(INT64)=0,out_bytes_rate(INT64)=0,out_total_bytes(INT64)=0,out_total_msgs(INT64)=0,collect_time(DATETIME)=2026-05-11 15:40:00,create_time(DATETIME)=2026-05-11 15:40:11}]]... 759 sinkTask-63==>DML[meta[monitor-stat_mq_queue_info_history,1778485211,INSERT,1778482891]post[Struct{id(INT64)=5226408505,tibco_alias(VAR_CHAR_STRING)=jq_cpd_x_02,name(VAR_CHAR_STRING)=mcas.mdp.billfeeQueue,url(VAR_CHAR_STRING)=tcp://tibco-cpd02-cloud02.99bill.com:7222,type(INT32)=1,static_tag(INT8)=1,receiver_count(INT32)=0,pending_msg_count(INT64)=0,pending_msg_size(INT64)=0,delivered_msg_count(INT64)=0,in_msg_rate(INT64)=0,in_bytes_rate(INT64)=0,in_total_bytes(INT64)=0,in_total_msgs(INT64)=0,out_msg_rate(INT64)=0,out_bytes_rate(INT64)=0,out_total_bytes(INT64)=0,out_total_msgs(INT64)=0,collect_time(DATETIME)=2026-05-11 15:40:00,create_time(DATETIME)=2026-05-11 15:40:11}]]... 760 ] 761 [2026-05-11 17:31:17.406] [WARN] [DRC-Client-Thread] [transaction is 1018_40312876, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 762 [2026-05-11 17:31:17.407] [WARN] [DRC-Client-Thread] [transaction is 1018_40312876, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 763 [2026-05-11 17:31:17.408] [WARN] [DRC-Client-Thread] [transaction is 1018_40312876, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 764 [2026-05-11 17:31:17.409] [WARN] [DRC-Client-Thread] [transaction is 1018_40312876, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 765 [2026-05-11 17:31:17.410] [WARN] [DRC-Client-Thread] [transaction is 1018_40312876, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 766 [2026-05-11 17:31:17.411] [WARN] [DRC-Client-Thread] [transaction is 1018_40312876, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 767 [2026-05-11 17:31:17.412] [WARN] [DRC-Client-Thread] [transaction is 1018_40312876, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 768 [2026-05-11 17:31:17.413] [WARN] [DRC-Client-Thread] [transaction is 1018_40312876, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 769 [2026-05-11 17:31:17.414] [WARN] [DRC-Client-Thread] [transaction is 1018_40312876, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 770 [2026-05-11 17:31:17.414] [WARN] [DRC-Client-Thread] [transaction is 1018_40312876, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 771 [2026-05-11 17:31:17.415] [WARN] [DRC-Client-Thread] [transaction is 1018_40312876, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 772 [2026-05-11 17:31:17.416] [WARN] [DRC-Client-Thread] [transaction is 1018_40312876, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 773 [2026-05-11 17:31:17.417] [WARN] [DRC-Client-Thread] [transaction is 1018_40312876, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 774 [2026-05-11 17:31:17.418] [WARN] [DRC-Client-Thread] [transaction is 1018_40312876, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 775 [2026-05-11 17:31:17.418] [WARN] [DRC-Client-Thread] [transaction is 1018_40312876, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 776 [2026-05-11 17:31:17.419] [WARN] [DRC-Client-Thread] [transaction is 1018_40312876, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 777 [2026-05-11 17:31:17.420] [WARN] [DRC-Client-Thread] [transaction is 1018_40312876, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 778 [2026-05-11 17:31:17.421] [WARN] [DRC-Client-Thread] [transaction is 1018_40312876, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 779 [2026-05-11 17:31:17.422] [WARN] [DRC-Client-Thread] [transaction is 1018_40312876, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 780 [2026-05-11 17:31:17.423] [WARN] [DRC-Client-Thread] [transaction is 1018_40312876, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 781 [2026-05-11 17:31:17.423] [WARN] [DRC-Client-Thread] [transaction is 1018_40312876, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 782 [2026-05-11 17:31:17.424] [WARN] [DRC-Client-Thread] [transaction is 1018_40312876, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 783 [2026-05-11 17:31:17.425] [WARN] [DRC-Client-Thread] [transaction is 1018_40312876, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 784 [2026-05-11 17:31:17.426] [WARN] [DRC-Client-Thread] [transaction is 1018_40312876, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 785 [2026-05-11 17:31:17.427] [WARN] [DRC-Client-Thread] [transaction is 1018_40312876, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 786 [2026-05-11 17:31:17.428] [WARN] [DRC-Client-Thread] [transaction is 1018_40312876, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 787 [2026-05-11 17:31:17.428] [WARN] [DRC-Client-Thread] [transaction is 1018_40312876, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 788 [2026-05-11 17:31:17.429] [WARN] [DRC-Client-Thread] [transaction is 1018_40312876, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 789 [2026-05-11 17:31:17.430] [WARN] [DRC-Client-Thread] [transaction is 1018_40312876, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 790 [2026-05-11 17:31:17.431] [WARN] [DRC-Client-Thread] [transaction is 1018_40312876, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 791 [2026-05-11 17:31:17.432] [WARN] [DRC-Client-Thread] [transaction is 1018_40312876, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 792 [2026-05-11 17:31:19.872] [WARN] [DRC-Client-Thread] [transaction is 1018_40316444, tableName is mq_collect_data, maxRecords is 64, cut it] 793 [2026-05-11 17:31:19.874] [WARN] [DRC-Client-Thread] [transaction is 1018_40316444, tableName is mq_collect_data, maxRecords is 64, cut it] 794 [2026-05-11 17:31:19.876] [WARN] [DRC-Client-Thread] [transaction is 1018_40316444, tableName is mq_collect_data, maxRecords is 64, cut it] 795 [2026-05-11 17:31:19.878] [WARN] [DRC-Client-Thread] [transaction is 1018_40316444, tableName is mq_collect_data, maxRecords is 64, cut it] 796 [2026-05-11 17:31:19.879] [WARN] [DRC-Client-Thread] [transaction is 1018_40316444, tableName is mq_collect_data, maxRecords is 64, cut it] 797 [2026-05-11 17:31:19.881] [WARN] [DRC-Client-Thread] [transaction is 1018_40316444, tableName is mq_collect_data, maxRecords is 64, cut it] 798 [2026-05-11 17:31:19.882] [WARN] [DRC-Client-Thread] [transaction is 1018_40316444, tableName is mq_collect_data, maxRecords is 64, cut it] 799 [2026-05-11 17:31:19.884] [WARN] [DRC-Client-Thread] [transaction is 1018_40316444, tableName is mq_collect_data, maxRecords is 64, cut it] 800 [2026-05-11 17:31:19.885] [WARN] [DRC-Client-Thread] [transaction is 1018_40316444, tableName is mq_collect_data, maxRecords is 64, cut it] 801 [2026-05-11 17:31:19.887] [WARN] [DRC-Client-Thread] [transaction is 1018_40316444, tableName is mq_collect_data, maxRecords is 64, cut it] 802 [2026-05-11 17:31:20.427] [WARN] [DRC-Client-Thread] [transaction is 1018_39574544, tableName is rrd_collect_data, maxRecords is 64, cut it] 803 [2026-05-11 17:31:20.428] [WARN] [DRC-Client-Thread] [transaction is 1018_39574544, tableName is rrd_collect_data, maxRecords is 64, cut it] 804 [2026-05-11 17:31:20.430] [WARN] [DRC-Client-Thread] [transaction is 1018_39574544, tableName is rrd_collect_data, maxRecords is 64, cut it] 805 [2026-05-11 17:31:22.452] [WARN] [DRC-Client-Thread] [transaction is 1018_40316474, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 806 [2026-05-11 17:31:22.453] [WARN] [DRC-Client-Thread] [transaction is 1018_40316474, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 807 [2026-05-11 17:31:22.455] [WARN] [DRC-Client-Thread] [transaction is 1018_40316474, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 808 [2026-05-11 17:31:22.457] [WARN] [DRC-Client-Thread] [transaction is 1018_40316474, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 809 [2026-05-11 17:31:22.458] [WARN] [DRC-Client-Thread] [transaction is 1018_40316474, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 810 [2026-05-11 17:31:22.460] [WARN] [DRC-Client-Thread] [transaction is 1018_40316474, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 811 [2026-05-11 17:31:22.462] [WARN] [DRC-Client-Thread] [transaction is 1018_40316474, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 812 [2026-05-11 17:31:22.463] [WARN] [DRC-Client-Thread] [transaction is 1018_40316474, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 813 [2026-05-11 17:31:22.465] [WARN] [DRC-Client-Thread] [transaction is 1018_40316474, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 814 [2026-05-11 17:31:22.466] [WARN] [DRC-Client-Thread] [transaction is 1018_40316474, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 815 [2026-05-11 17:31:22.467] [WARN] [DRC-Client-Thread] [transaction is 1018_40316474, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 816 [2026-05-11 17:31:22.468] [WARN] [DRC-Client-Thread] [transaction is 1018_40316474, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 817 [2026-05-11 17:31:22.469] [WARN] [DRC-Client-Thread] [transaction is 1018_40316474, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 818 [2026-05-11 17:31:22.470] [WARN] [DRC-Client-Thread] [transaction is 1018_40316474, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 819 [2026-05-11 17:31:22.471] [WARN] [DRC-Client-Thread] [transaction is 1018_40316474, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 820 [2026-05-11 17:31:22.472] [WARN] [DRC-Client-Thread] [transaction is 1018_40316474, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 821 [2026-05-11 17:31:22.473] [WARN] [DRC-Client-Thread] [transaction is 1018_40316474, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 822 [2026-05-11 17:31:22.474] [WARN] [DRC-Client-Thread] [transaction is 1018_40316474, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 823 [2026-05-11 17:31:22.476] [WARN] [DRC-Client-Thread] [transaction is 1018_40316474, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 824 [2026-05-11 17:31:22.477] [WARN] [DRC-Client-Thread] [transaction is 1018_40316474, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 825 [2026-05-11 17:31:22.478] [WARN] [DRC-Client-Thread] [transaction is 1018_40316474, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 826 [2026-05-11 17:31:22.480] [WARN] [DRC-Client-Thread] [transaction is 1018_40316474, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 827 [2026-05-11 17:31:22.481] [WARN] [DRC-Client-Thread] [transaction is 1018_40316474, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 828 [2026-05-11 17:31:22.482] [WARN] [DRC-Client-Thread] [transaction is 1018_40316474, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 829 [2026-05-11 17:31:22.483] [WARN] [DRC-Client-Thread] [transaction is 1018_40316474, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 830 [2026-05-11 17:31:22.484] [WARN] [DRC-Client-Thread] [transaction is 1018_40316474, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 831 [2026-05-11 17:31:22.486] [WARN] [DRC-Client-Thread] [transaction is 1018_40316474, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 832 [2026-05-11 17:31:22.487] [WARN] [DRC-Client-Thread] [transaction is 1018_40316474, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 833 [2026-05-11 17:31:27.256] [INFO] [forward_slot0-(ETLProcessor)-queue_slot1] [table name [t_amon_txn_qr_033] set for ddl [create /*+ parallel(4) */ index if not exists `IDX_AMONQR_MER_ID_EXTNO` on `t_amon_txn_qr_033` (`MERCHANT_ID` ASC, `EXT_TRACE_NO` ASC) LOCAL]] 834 [2026-05-11 17:31:27.256] [WARN] [forward_slot0-(ETLProcessor)-queue_slot1] [DDLTransfer: ddl should be filtered, dbname:ate.ate, ddl: create /*+ parallel(4) */ index if not exists `IDX_AMONQR_MER_ID_EXTNO` on `t_amon_txn_qr_033` (`MERCHANT_ID` ASC, `EXT_TRACE_NO` ASC) LOCAL] 835 [2026-05-11 17:31:27.256] [INFO] [forward_slot0-(ETLProcessor)-queue_slot1] [DDLTransfer: ddl create /*+ parallel(4) */ index if not exists `IDX_AMONQR_MER_ID_EXTNO` on `t_amon_txn_qr_033` (`MERCHANT_ID` ASC, `EXT_TRACE_NO` ASC) LOCAL filter with map db null, with record db [ate.ate], table [null], parsed db[ate.ate], table[t_amon_txn_qr_033], dbToMap[ate.ate], tbToMap[t_amon_txn_qr_033]] 836 [2026-05-11 17:31:33.201] [WARN] [DRC-Client-Thread] [transaction is 1018_39574918, tableName is redis_collect_data, maxRecords is 64, cut it] 837 [2026-05-11 17:31:33.484] [WARN] [DRC-Client-Thread] [transaction is 1018_39574934, tableName is rrd_collect_data, maxRecords is 64, cut it] 838 [2026-05-11 17:31:33.485] [WARN] [DRC-Client-Thread] [transaction is 1018_39574934, tableName is rrd_collect_data, maxRecords is 64, cut it] 839 [2026-05-11 17:31:33.485] [WARN] [DRC-Client-Thread] [transaction is 1018_39574934, tableName is rrd_collect_data, maxRecords is 64, cut it] 840 [2026-05-11 17:31:39.185] [INFO] [forward_slot0-(ETLProcessor)-queue_slot1] [table name [t_amon_txn_qr_033] set for ddl [create /*+ parallel(4) */ index if not exists `IDX_AMONQR_TERM_ID_TRACENO` on `t_amon_txn_qr_033` (`TERMINAL_ID` ASC, `TERM_TRACE_NO` ASC) LOCAL]] 841 [2026-05-11 17:31:39.185] [WARN] [forward_slot0-(ETLProcessor)-queue_slot1] [DDLTransfer: ddl should be filtered, dbname:ate.ate, ddl: create /*+ parallel(4) */ index if not exists `IDX_AMONQR_TERM_ID_TRACENO` on `t_amon_txn_qr_033` (`TERMINAL_ID` ASC, `TERM_TRACE_NO` ASC) LOCAL] 842 [2026-05-11 17:31:39.185] [INFO] [forward_slot0-(ETLProcessor)-queue_slot1] [DDLTransfer: ddl create /*+ parallel(4) */ index if not exists `IDX_AMONQR_TERM_ID_TRACENO` on `t_amon_txn_qr_033` (`TERMINAL_ID` ASC, `TERM_TRACE_NO` ASC) LOCAL filter with map db null, with record db [ate.ate], table [null], parsed db[ate.ate], table[t_amon_txn_qr_033], dbToMap[ate.ate], tbToMap[t_amon_txn_qr_033]] 843 [2026-05-11 17:31:45.338] [WARN] [DRC-Client-Thread] [transaction is 1018_39575152, tableName is rrd_collect_data, maxRecords is 64, cut it] 844 [2026-05-11 17:31:45.339] [WARN] [DRC-Client-Thread] [transaction is 1018_39575152, tableName is rrd_collect_data, maxRecords is 64, cut it] 845 [2026-05-11 17:31:45.340] [WARN] [DRC-Client-Thread] [transaction is 1018_39575152, tableName is rrd_collect_data, maxRecords is 64, cut it] 846 [2026-05-11 17:31:45.341] [WARN] [DRC-Client-Thread] [transaction is 1018_39575152, tableName is rrd_collect_data, maxRecords is 64, cut it] 847 [2026-05-11 17:31:45.342] [WARN] [DRC-Client-Thread] [transaction is 1018_39575152, tableName is rrd_collect_data, maxRecords is 64, cut it] 848 [2026-05-11 17:31:45.342] [WARN] [DRC-Client-Thread] [transaction is 1018_39575152, tableName is rrd_collect_data, maxRecords is 64, cut it] 849 [2026-05-11 17:31:45.343] [WARN] [DRC-Client-Thread] [transaction is 1018_39575152, tableName is rrd_collect_data, maxRecords is 64, cut it] 850 [2026-05-11 17:31:52.798] [INFO] [DRC-Client-Thread] [notify consume: 0.01962519446783609 ms] 851 [2026-05-11 17:31:56.581] [INFO] [forward_slot0-(ETLProcessor)-queue_slot1] [table name [t_amon_txn_qr_033] set for ddl [create /*+ parallel(4) */ index if not exists `IDX_AMONQR_TXN_TIME` on `t_amon_txn_qr_033` (`TXN_TIME` ASC) LOCAL]] 852 [2026-05-11 17:31:56.581] [WARN] [forward_slot0-(ETLProcessor)-queue_slot1] [DDLTransfer: ddl should be filtered, dbname:ate.ate, ddl: create /*+ parallel(4) */ index if not exists `IDX_AMONQR_TXN_TIME` on `t_amon_txn_qr_033` (`TXN_TIME` ASC) LOCAL] 853 [2026-05-11 17:31:56.581] [INFO] [forward_slot0-(ETLProcessor)-queue_slot1] [DDLTransfer: ddl create /*+ parallel(4) */ index if not exists `IDX_AMONQR_TXN_TIME` on `t_amon_txn_qr_033` (`TXN_TIME` ASC) LOCAL filter with map db null, with record db [ate.ate], table [null], parsed db[ate.ate], table[t_amon_txn_qr_033], dbToMap[ate.ate], tbToMap[t_amon_txn_qr_033]] 854 [2026-05-11 17:32:06.157] [WARN] [DRC-Client-Thread] [transaction is 1018_39575356, tableName is rrd_collect_data, maxRecords is 64, cut it] 855 [2026-05-11 17:32:06.158] [WARN] [DRC-Client-Thread] [transaction is 1018_39575356, tableName is rrd_collect_data, maxRecords is 64, cut it] 856 [2026-05-11 17:32:06.159] [WARN] [DRC-Client-Thread] [transaction is 1018_39575356, tableName is rrd_collect_data, maxRecords is 64, cut it] 857 [2026-05-11 17:32:06.160] [WARN] [DRC-Client-Thread] [transaction is 1018_39575356, tableName is rrd_collect_data, maxRecords is 64, cut it] 858 [2026-05-11 17:32:06.474] [INFO] [forward_slot0-(ETLProcessor)-queue_slot1] [table name [t_amon_order_024] set for ddl [create /*+ parallel(4) */ index if not exists `IDX_AMONORD_CREATE_TIME` on `t_amon_order_024` (`CREATE_TIME` ASC) LOCAL]] 859 [2026-05-11 17:32:06.474] [WARN] [forward_slot0-(ETLProcessor)-queue_slot1] [DDLTransfer: ddl should be filtered, dbname:ate.ate, ddl: create /*+ parallel(4) */ index if not exists `IDX_AMONORD_CREATE_TIME` on `t_amon_order_024` (`CREATE_TIME` ASC) LOCAL] 860 [2026-05-11 17:32:06.474] [INFO] [forward_slot0-(ETLProcessor)-queue_slot1] [DDLTransfer: ddl create /*+ parallel(4) */ index if not exists `IDX_AMONORD_CREATE_TIME` on `t_amon_order_024` (`CREATE_TIME` ASC) LOCAL filter with map db null, with record db [ate.ate], table [null], parsed db[ate.ate], table[t_amon_order_024], dbToMap[ate.ate], tbToMap[t_amon_order_024]] 861 [2026-05-11 17:32:08.468] [WARN] [DRC-Client-Thread] [transaction is 1018_40323716, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 862 [2026-05-11 17:32:08.468] [WARN] [DRC-Client-Thread] [transaction is 1018_40323716, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 863 [2026-05-11 17:32:08.469] [WARN] [DRC-Client-Thread] [transaction is 1018_40323716, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 864 [2026-05-11 17:32:08.470] [WARN] [DRC-Client-Thread] [transaction is 1018_40323716, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 865 [2026-05-11 17:32:08.471] [WARN] [DRC-Client-Thread] [transaction is 1018_40323716, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 866 [2026-05-11 17:32:08.472] [WARN] [DRC-Client-Thread] [transaction is 1018_40323716, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 867 [2026-05-11 17:32:08.473] [WARN] [DRC-Client-Thread] [transaction is 1018_40323716, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 868 [2026-05-11 17:32:08.474] [WARN] [DRC-Client-Thread] [transaction is 1018_40323716, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 869 [2026-05-11 17:32:08.475] [WARN] [DRC-Client-Thread] [transaction is 1018_40323716, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 870 [2026-05-11 17:32:08.476] [WARN] [DRC-Client-Thread] [transaction is 1018_40323716, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 871 [2026-05-11 17:32:08.477] [WARN] [DRC-Client-Thread] [transaction is 1018_40323716, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 872 [2026-05-11 17:32:08.477] [WARN] [DRC-Client-Thread] [transaction is 1018_40323716, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 873 [2026-05-11 17:32:08.479] [WARN] [DRC-Client-Thread] [transaction is 1018_40323716, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 874 [2026-05-11 17:32:08.480] [WARN] [DRC-Client-Thread] [transaction is 1018_40323716, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 875 [2026-05-11 17:32:08.481] [WARN] [DRC-Client-Thread] [transaction is 1018_40323716, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 876 [2026-05-11 17:32:08.482] [WARN] [DRC-Client-Thread] [transaction is 1018_40323716, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 877 [2026-05-11 17:32:08.483] [WARN] [DRC-Client-Thread] [transaction is 1018_40323716, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 878 [2026-05-11 17:32:08.484] [WARN] [DRC-Client-Thread] [transaction is 1018_40323716, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 879 [2026-05-11 17:32:08.485] [WARN] [DRC-Client-Thread] [transaction is 1018_40323716, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 880 [2026-05-11 17:32:08.486] [WARN] [DRC-Client-Thread] [transaction is 1018_40323716, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 881 [2026-05-11 17:32:08.487] [WARN] [DRC-Client-Thread] [transaction is 1018_40323716, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 882 [2026-05-11 17:32:08.487] [WARN] [DRC-Client-Thread] [transaction is 1018_40323716, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 883 [2026-05-11 17:32:08.488] [WARN] [DRC-Client-Thread] [transaction is 1018_40323716, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 884 [2026-05-11 17:32:08.489] [WARN] [DRC-Client-Thread] [transaction is 1018_40323716, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 885 [2026-05-11 17:32:08.490] [WARN] [DRC-Client-Thread] [transaction is 1018_40323716, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 886 [2026-05-11 17:32:08.491] [WARN] [DRC-Client-Thread] [transaction is 1018_40323716, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 887 [2026-05-11 17:32:08.492] [WARN] [DRC-Client-Thread] [transaction is 1018_40323716, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 888 [2026-05-11 17:32:08.493] [WARN] [DRC-Client-Thread] [transaction is 1018_40323716, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 889 [2026-05-11 17:32:08.493] [WARN] [DRC-Client-Thread] [transaction is 1018_40323716, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 890 [2026-05-11 17:32:08.494] [WARN] [DRC-Client-Thread] [transaction is 1018_40323716, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 891 [2026-05-11 17:32:08.495] [WARN] [DRC-Client-Thread] [transaction is 1018_40323716, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 892 [2026-05-11 17:32:11.554] [WARN] [DRC-Client-Thread] [transaction is 1018_40327344, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 893 [2026-05-11 17:32:11.555] [WARN] [DRC-Client-Thread] [transaction is 1018_40327344, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 894 [2026-05-11 17:32:11.559] [WARN] [DRC-Client-Thread] [transaction is 1018_40327344, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 895 [2026-05-11 17:32:11.560] [WARN] [DRC-Client-Thread] [transaction is 1018_40327344, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 896 [2026-05-11 17:32:11.560] [WARN] [DRC-Client-Thread] [transaction is 1018_40327344, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 897 [2026-05-11 17:32:11.561] [WARN] [DRC-Client-Thread] [transaction is 1018_40327344, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 898 [2026-05-11 17:32:11.562] [WARN] [DRC-Client-Thread] [transaction is 1018_40327344, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 899 [2026-05-11 17:32:11.563] [WARN] [DRC-Client-Thread] [transaction is 1018_40327344, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 900 [2026-05-11 17:32:11.563] [WARN] [DRC-Client-Thread] [transaction is 1018_40327344, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 901 [2026-05-11 17:32:11.564] [WARN] [DRC-Client-Thread] [transaction is 1018_40327344, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 902 [2026-05-11 17:32:11.565] [WARN] [DRC-Client-Thread] [transaction is 1018_40327344, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 903 [2026-05-11 17:32:11.565] [WARN] [DRC-Client-Thread] [transaction is 1018_40327344, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 904 [2026-05-11 17:32:11.566] [WARN] [DRC-Client-Thread] [transaction is 1018_40327344, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 905 [2026-05-11 17:32:11.567] [WARN] [DRC-Client-Thread] [transaction is 1018_40327344, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 906 [2026-05-11 17:32:11.568] [WARN] [DRC-Client-Thread] [transaction is 1018_40327344, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 907 [2026-05-11 17:32:11.568] [WARN] [DRC-Client-Thread] [transaction is 1018_40327344, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 908 [2026-05-11 17:32:11.569] [WARN] [DRC-Client-Thread] [transaction is 1018_40327344, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 909 [2026-05-11 17:32:11.570] [WARN] [DRC-Client-Thread] [transaction is 1018_40327344, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 910 [2026-05-11 17:32:11.571] [WARN] [DRC-Client-Thread] [transaction is 1018_40327344, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 911 [2026-05-11 17:32:11.571] [WARN] [DRC-Client-Thread] [transaction is 1018_40327344, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 912 [2026-05-11 17:32:11.572] [WARN] [DRC-Client-Thread] [transaction is 1018_40327344, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 913 [2026-05-11 17:32:11.573] [WARN] [DRC-Client-Thread] [transaction is 1018_40327344, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 914 [2026-05-11 17:32:11.573] [WARN] [DRC-Client-Thread] [transaction is 1018_40327344, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 915 [2026-05-11 17:32:11.574] [WARN] [DRC-Client-Thread] [transaction is 1018_40327344, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 916 [2026-05-11 17:32:11.575] [WARN] [DRC-Client-Thread] [transaction is 1018_40327344, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 917 [2026-05-11 17:32:11.576] [WARN] [DRC-Client-Thread] [transaction is 1018_40327344, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 918 [2026-05-11 17:32:11.577] [WARN] [DRC-Client-Thread] [transaction is 1018_40327344, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 919 [2026-05-11 17:32:11.577] [WARN] [DRC-Client-Thread] [transaction is 1018_40327344, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 920 [2026-05-11 17:32:11.578] [WARN] [DRC-Client-Thread] [transaction is 1018_40327344, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 921 [2026-05-11 17:32:11.579] [WARN] [DRC-Client-Thread] [transaction is 1018_40327344, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 922 [2026-05-11 17:32:11.580] [WARN] [DRC-Client-Thread] [transaction is 1018_40327344, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 923 [2026-05-11 17:32:16.924] [INFO] [timerTaskScheduler] [ 924 sinkTaskProcesslist 925 sinkTask-12==>DML[meta[monitor-rrd_collect_data,1778485272,INSERT,1778482891]post[Struct{id(INT32)=217255315,product_id(VAR_CHAR_STRING)=FIC,group_id(VAR_CHAR_STRING)=201801185,picture_id(VAR_CHAR_STRING)=2018011808,value(INT32)=100,metric(VAR_CHAR_STRING)=RADIO,time(DATETIME)=2026-05-11 15:35:00,title(VAR_CHAR_STRING)=BANKCPS-银行通道-中国网联快捷_ZGWL0101-5分钟消费鉴权成功率,create_time(DATETIME)=2026-05-11 15:41:12,monitor_model(INT32)=0}]]... 926 sinkTask-17==>DML[meta[monitor-stat_mq_queue_info_history,1778485272,INSERT,1778482891]post[Struct{id(INT64)=5226417176,tibco_alias(VAR_CHAR_STRING)=jq_cpd_x_cloud,name(VAR_CHAR_STRING)=bgw.mdp.RequestQueue.01051000,url(VAR_CHAR_STRING)=tcp://tibco-cpd-cloud01.99bill.com:7222,type(INT32)=1,static_tag(INT8)=1,receiver_count(INT32)=0,pending_msg_count(INT64)=0,pending_msg_size(INT64)=0,delivered_msg_count(INT64)=0,in_msg_rate(INT64)=0,in_bytes_rate(INT64)=0,in_total_bytes(INT64)=0,in_total_msgs(INT64)=0,out_msg_rate(INT64)=0,out_bytes_rate(INT64)=0,out_total_bytes(INT64)=0,out_total_msgs(INT64)=0,collect_time(DATETIME)=2026-05-11 15:41:00,create_time(DATETIME)=2026-05-11 15:41:11}]]... 927 sinkTask-18==>DML[meta[monitor-stat_mq_queue_info,1778485272,UPDATE,1778482891]prev[Struct{id(INT32)=14645,tibco_alias(VAR_CHAR_STRING)=jq_pix_c,url(VAR_CHAR_STRING)=tibco-pix-i02.99bill.com:7222,name(VAR_CHAR_STRING)=bgw.mdp.RequestQueue.01040010,type(INT32)=1,static_tag(INT8)=1,product_id(VAR_CHAR_STRING)=DEFAULT,description(VAR_CHAR_STRING)=,alarm_settings(VAR_CHAR_STRING)=,on_tag(INT8)=1,receiver_count(INT32)=0,pending_msg_count(INT64)=0,pending_msg_size(INT64)=0,delivered_msg_count(INT64)=0,in_msg_rate(INT64)=0,in_bytes_rate(INT64)=0,in_total_bytes(INT64)=0,in_total_msgs(INT64)=0,out_msg_rate(INT64)=0,out_bytes_rate(INT64)=0,out_total_bytes(INT64)=0,out_total_msgs(INT64)=0,collect_time(DATETIME)=2026-05-11 15:40:00,create_time(DATETIME)=2023-08-23 13:56:01,update_time(DATETIME)=2023-08-23 13:56:01}] post[Struct{id(INT32)=14645,tibco_alias(VAR_CHAR_STRING)=jq_pix_c,url(VAR_CHAR_STRING)=tibco-pix-i02.99bill.com:7222,name(VAR_CHAR_STRING)=bgw.mdp.RequestQueue.01040010,type(INT32)=1,static_tag(INT8)=1,product_id(VAR_CHAR_STRING)=DEFAULT,description(VAR_CHAR_STRING)=,alarm_settings(VAR_CHAR_STRING)=,on_tag(INT8)=1,receiver_count(INT32)=0,pending_msg_count(INT64)=0,pending_msg_size(INT64)=0,delivered_msg_count(INT64)=0,in_msg_rate(INT64)=0,in_bytes_rate(INT64)=0,in_total_bytes(INT64)=0,in_total_msgs(INT64)=0,out_msg_rate(INT64)=0,out_bytes_rate(INT64)=0,out_total_bytes(INT64)=0,out_total_msgs(INT64)=0,collect_time(DATETIME)=2026-05-11 15:41:00,create_time(DATETIME)=2023-08-23 13:56:01,update_time(DATETIME)=2023-08-23 13:56:01}]]... 928 sinkTask-21==>DML[meta[monitor-rrd_qrtz_fired_triggers,1778485272,DELETE,1778482891]prev[Struct{ENTRY_ID(VAR_CHAR_STRING)=app-monitor-website-6484cb594d-9vsdb17784842426701778484243798,TRIGGER_NAME(VAR_CHAR_STRING)=Graph_CPS,TRIGGER_GROUP(VAR_CHAR_STRING)=2024040105,IS_VOLATILE(VAR_CHAR_STRING)=0,INSTANCE_NAME(VAR_CHAR_STRING)=app-monitor-website-6484cb594d-9vsdb1778484242670,FIRED_TIME(INT64)=1778485205000,PRIORITY(INT32)=5,STATE(VAR_CHAR_STRING)=ACQUIRED,JOB_NAME(VAR_CHAR_STRING)=null,JOB_GROUP(VAR_CHAR_STRING)=null,IS_STATEFUL(VAR_CHAR_STRING)=0,REQUESTS_RECOVERY(VAR_CHAR_STRING)=0}] ]... 929 sinkTask-26==>DML[meta[monitor-rrd_collect_data,1778485272,INSERT,1778482891]post[Struct{id(INT32)=217255314,product_id(VAR_CHAR_STRING)=FIC,group_id(VAR_CHAR_STRING)=201801185,picture_id(VAR_CHAR_STRING)=2018011808,value(INT32)=181,metric(VAR_CHAR_STRING)=SUCCESS,time(DATETIME)=2026-05-11 15:35:00,title(VAR_CHAR_STRING)=BANKCPS-银行通道-中国网联快捷_ZGWL0101-5分钟消费鉴权成功率,create_time(DATETIME)=2026-05-11 15:41:12,monitor_model(INT32)=0}]]... 930 sinkTask-27==>DML[meta[monitor-stat_mq_queue_info_history,1778485272,INSERT,1778482891]post[Struct{id(INT64)=5226417177,tibco_alias(VAR_CHAR_STRING)=jq_cps_t,name(VAR_CHAR_STRING)=bgw.mdp.RequestQueue.01031000,url(VAR_CHAR_STRING)=tcp://tibco-cps-t01.99bill.com:7222,type(INT32)=1,static_tag(INT8)=1,receiver_count(INT32)=0,pending_msg_count(INT64)=0,pending_msg_size(INT64)=0,delivered_msg_count(INT64)=0,in_msg_rate(INT64)=0,in_bytes_rate(INT64)=0,in_total_bytes(INT64)=0,in_total_msgs(INT64)=0,out_msg_rate(INT64)=0,out_bytes_rate(INT64)=0,out_total_bytes(INT64)=0,out_total_msgs(INT64)=0,collect_time(DATETIME)=2026-05-11 15:41:00,create_time(DATETIME)=2026-05-11 15:41:11}]]... 931 sinkTask-30==>DML[meta[monitor-stat_mq_queue_info_history,1778485272,INSERT,1778482891]post[Struct{id(INT64)=5226417171,tibco_alias(VAR_CHAR_STRING)=jq_cps_t,name(VAR_CHAR_STRING)=bgw.mdp.RequestQueue.01030003,url(VAR_CHAR_STRING)=tcp://tibco-cps-t01.99bill.com:7222,type(INT32)=1,static_tag(INT8)=1,receiver_count(INT32)=0,pending_msg_count(INT64)=0,pending_msg_size(INT64)=0,delivered_msg_count(INT64)=0,in_msg_rate(INT64)=0,in_bytes_rate(INT64)=0,in_total_bytes(INT64)=0,in_total_msgs(INT64)=0,out_msg_rate(INT64)=0,out_bytes_rate(INT64)=0,out_total_bytes(INT64)=0,out_total_msgs(INT64)=0,collect_time(DATETIME)=2026-05-11 15:41:00,create_time(DATETIME)=2026-05-11 15:41:11}]]... 932 sinkTask-33==>DML[meta[monitor-stat_mq_queue_info_history,1778485272,INSERT,1778482891]post[Struct{id(INT64)=5226417172,tibco_alias(VAR_CHAR_STRING)=jq_cpd_x_cloud,name(VAR_CHAR_STRING)=bgw.mdp.RequestQueue.01050101,url(VAR_CHAR_STRING)=tcp://tibco-cpd-cloud01.99bill.com:7222,type(INT32)=1,static_tag(INT8)=1,receiver_count(INT32)=0,pending_msg_count(INT64)=0,pending_msg_size(INT64)=0,delivered_msg_count(INT64)=0,in_msg_rate(INT64)=0,in_bytes_rate(INT64)=0,in_total_bytes(INT64)=0,in_total_msgs(INT64)=0,out_msg_rate(INT64)=0,out_bytes_rate(INT64)=0,out_total_bytes(INT64)=0,out_total_msgs(INT64)=0,collect_time(DATETIME)=2026-05-11 15:41:00,create_time(DATETIME)=2026-05-11 15:41:11}]]... 933 sinkTask-38==>DML[meta[monitor-stat_mq_queue_info,1778485272,UPDATE,1778482891]prev[Struct{id(INT32)=14648,tibco_alias(VAR_CHAR_STRING)=jq_pix_c,url(VAR_CHAR_STRING)=tibco-pix-i02.99bill.com:7222,name(VAR_CHAR_STRING)=bgw.mdp.RequestQueue.01050001,type(INT32)=1,static_tag(INT8)=1,product_id(VAR_CHAR_STRING)=DEFAULT,description(VAR_CHAR_STRING)=,alarm_settings(VAR_CHAR_STRING)=,on_tag(INT8)=1,receiver_count(INT32)=0,pending_msg_count(INT64)=0,pending_msg_size(INT64)=0,delivered_msg_count(INT64)=0,in_msg_rate(INT64)=0,in_bytes_rate(INT64)=0,in_total_bytes(INT64)=0,in_total_msgs(INT64)=0,out_msg_rate(INT64)=0,out_bytes_rate(INT64)=0,out_total_bytes(INT64)=0,out_total_msgs(INT64)=0,collect_time(DATETIME)=2026-05-11 15:40:00,create_time(DATETIME)=2023-08-23 13:56:01,update_time(DATETIME)=2023-08-23 13:56:01}] post[Struct{id(INT32)=14648,tibco_alias(VAR_CHAR_STRING)=jq_pix_c,url(VAR_CHAR_STRING)=tibco-pix-i02.99bill.com:7222,name(VAR_CHAR_STRING)=bgw.mdp.RequestQueue.01050001,type(INT32)=1,static_tag(INT8)=1,product_id(VAR_CHAR_STRING)=DEFAULT,description(VAR_CHAR_STRING)=,alarm_settings(VAR_CHAR_STRING)=,on_tag(INT8)=1,receiver_count(INT32)=0,pending_msg_count(INT64)=0,pending_msg_size(INT64)=0,delivered_msg_count(INT64)=0,in_msg_rate(INT64)=0,in_bytes_rate(INT64)=0,in_total_bytes(INT64)=0,in_total_msgs(INT64)=0,out_msg_rate(INT64)=0,out_bytes_rate(INT64)=0,out_total_bytes(INT64)=0,out_total_msgs(INT64)=0,collect_time(DATETIME)=2026-05-11 15:41:00,create_time(DATETIME)=2023-08-23 13:56:01,update_time(DATETIME)=2023-08-23 13:56:01}]]... 934 sinkTask-45==>DML[meta[monitor-stat_mq_queue_info_history,1778485272,INSERT,1778482891]post[Struct{id(INT64)=5226417175,tibco_alias(VAR_CHAR_STRING)=jq_cps_t,name(VAR_CHAR_STRING)=bgw.mdp.RequestQueue.01030103,url(VAR_CHAR_STRING)=tcp://tibco-cps-t01.99bill.com:7222,type(INT32)=1,static_tag(INT8)=1,receiver_count(INT32)=0,pending_msg_count(INT64)=0,pending_msg_size(INT64)=0,delivered_msg_count(INT64)=0,in_msg_rate(INT64)=0,in_bytes_rate(INT64)=0,in_total_bytes(INT64)=0,in_total_msgs(INT64)=0,out_msg_rate(INT64)=0,out_bytes_rate(INT64)=0,out_total_bytes(INT64)=0,out_total_msgs(INT64)=0,collect_time(DATETIME)=2026-05-11 15:41:00,create_time(DATETIME)=2026-05-11 15:41:11}]]... 935 sinkTask-46==>DML[meta[monitor-stat_mq_queue_info_history,1778485272,INSERT,1778482891]post[Struct{id(INT64)=5226417174,tibco_alias(VAR_CHAR_STRING)=jq_cpd_x_cloud,name(VAR_CHAR_STRING)=bgw.mdp.RequestQueue.01050301,url(VAR_CHAR_STRING)=tcp://tibco-cpd-cloud01.99bill.com:7222,type(INT32)=1,static_tag(INT8)=1,receiver_count(INT32)=0,pending_msg_count(INT64)=0,pending_msg_size(INT64)=0,delivered_msg_count(INT64)=0,in_msg_rate(INT64)=0,in_bytes_rate(INT64)=0,in_total_bytes(INT64)=0,in_total_msgs(INT64)=0,out_msg_rate(INT64)=0,out_bytes_rate(INT64)=0,out_total_bytes(INT64)=0,out_total_msgs(INT64)=0,collect_time(DATETIME)=2026-05-11 15:41:00,create_time(DATETIME)=2026-05-11 15:41:11}]]... 936 sinkTask-48==>DML[meta[monitor-stat_mq_queue_info,1778485272,UPDATE,1778482891]prev[Struct{id(INT32)=14647,tibco_alias(VAR_CHAR_STRING)=jq_pix_c,url(VAR_CHAR_STRING)=tibco-pix-i02.99bill.com:7222,name(VAR_CHAR_STRING)=bgw.mdp.RequestQueue.01049900,type(INT32)=1,static_tag(INT8)=1,product_id(VAR_CHAR_STRING)=DEFAULT,description(VAR_CHAR_STRING)=,alarm_settings(VAR_CHAR_STRING)=,on_tag(INT8)=1,receiver_count(INT32)=0,pending_msg_count(INT64)=0,pending_msg_size(INT64)=0,delivered_msg_count(INT64)=0,in_msg_rate(INT64)=0,in_bytes_rate(INT64)=0,in_total_bytes(INT64)=0,in_total_msgs(INT64)=0,out_msg_rate(INT64)=0,out_bytes_rate(INT64)=0,out_total_bytes(INT64)=0,out_total_msgs(INT64)=0,collect_time(DATETIME)=2026-05-11 15:40:00,create_time(DATETIME)=2023-08-23 13:56:01,update_time(DATETIME)=2023-08-23 13:56:01}] post[Struct{id(INT32)=14647,tibco_alias(VAR_CHAR_STRING)=jq_pix_c,url(VAR_CHAR_STRING)=tibco-pix-i02.99bill.com:7222,name(VAR_CHAR_STRING)=bgw.mdp.RequestQueue.01049900,type(INT32)=1,static_tag(INT8)=1,product_id(VAR_CHAR_STRING)=DEFAULT,description(VAR_CHAR_STRING)=,alarm_settings(VAR_CHAR_STRING)=,on_tag(INT8)=1,receiver_count(INT32)=0,pending_msg_count(INT64)=0,pending_msg_size(INT64)=0,delivered_msg_count(INT64)=0,in_msg_rate(INT64)=0,in_bytes_rate(INT64)=0,in_total_bytes(INT64)=0,in_total_msgs(INT64)=0,out_msg_rate(INT64)=0,out_bytes_rate(INT64)=0,out_total_bytes(INT64)=0,out_total_msgs(INT64)=0,collect_time(DATETIME)=2026-05-11 15:41:00,create_time(DATETIME)=2023-08-23 13:56:01,update_time(DATETIME)=2023-08-23 13:56:01}]]... 937 sinkTask-50==>DML[meta[monitor-stat_mq_queue_info_history,1778485272,INSERT,1778482891]post[Struct{id(INT64)=5226417178,tibco_alias(VAR_CHAR_STRING)=jq_cps_t,name(VAR_CHAR_STRING)=bgw.mdp.RequestQueue.01031003,url(VAR_CHAR_STRING)=tcp://tibco-cps-t01.99bill.com:7222,type(INT32)=1,static_tag(INT8)=1,receiver_count(INT32)=0,pending_msg_count(INT64)=0,pending_msg_size(INT64)=0,delivered_msg_count(INT64)=0,in_msg_rate(INT64)=0,in_bytes_rate(INT64)=0,in_total_bytes(INT64)=0,in_total_msgs(INT64)=0,out_msg_rate(INT64)=0,out_bytes_rate(INT64)=0,out_total_bytes(INT64)=0,out_total_msgs(INT64)=0,collect_time(DATETIME)=2026-05-11 15:41:00,create_time(DATETIME)=2026-05-11 15:41:11}]]... 938 sinkTask-57==>DML[meta[monitor-stat_mq_queue_info_history,1778485272,INSERT,1778482891]post[Struct{id(INT64)=5226417173,tibco_alias(VAR_CHAR_STRING)=jq_cps_t,name(VAR_CHAR_STRING)=bgw.mdp.RequestQueue.01030102,url(VAR_CHAR_STRING)=tcp://tibco-cps-t01.99bill.com:7222,type(INT32)=1,static_tag(INT8)=1,receiver_count(INT32)=0,pending_msg_count(INT64)=0,pending_msg_size(INT64)=0,delivered_msg_count(INT64)=0,in_msg_rate(INT64)=0,in_bytes_rate(INT64)=0,in_total_bytes(INT64)=0,in_total_msgs(INT64)=0,out_msg_rate(INT64)=0,out_bytes_rate(INT64)=0,out_total_bytes(INT64)=0,out_total_msgs(INT64)=0,collect_time(DATETIME)=2026-05-11 15:41:00,create_time(DATETIME)=2026-05-11 15:41:11}]]... 939 sinkTask-58==>DML[meta[monitor-rrd_qrtz_triggers,1778485272,UPDATE,1778482891]prev[Struct{TRIGGER_NAME(VAR_CHAR_STRING)=Graph_CPS,TRIGGER_GROUP(VAR_CHAR_STRING)=2024040103,JOB_NAME(VAR_CHAR_STRING)=Graph_CPS,JOB_GROUP(VAR_CHAR_STRING)=2024040103,IS_VOLATILE(VAR_CHAR_STRING)=0,DESCRIPTION(VAR_CHAR_STRING)=null,NEXT_FIRE_TIME(INT64)=1778485205000,PREV_FIRE_TIME(INT64)=1778484905000,PRIORITY(INT32)=5,TRIGGER_STATE(VAR_CHAR_STRING)=ACQUIRED,TRIGGER_TYPE(VAR_CHAR_STRING)=CRON,START_TIME(INT64)=1744717707000,END_TIME(INT64)=0,CALENDAR_NAME(VAR_CHAR_STRING)=null,MISFIRE_INSTR(INT16)=0,JOB_DATA(BLOB)=}] post[Struct{TRIGGER_NAME(VAR_CHAR_STRING)=Graph_CPS,TRIGGER_GROUP(VAR_CHAR_STRING)=2024040103,JOB_NAME(VAR_CHAR_STRING)=Graph_CPS,JOB_GROUP(VAR_CHAR_STRING)=2024040103,IS_VOLATILE(VAR_CHAR_STRING)=0,DESCRIPTION(VAR_CHAR_STRING)=null,NEXT_FIRE_TIME(INT64)=1778485205000,PREV_FIRE_TIME(INT64)=1778484905000,PRIORITY(INT32)=5,TRIGGER_STATE(VAR_CHAR_STRING)=WAITING,TRIGGER_TYPE(VAR_CHAR_STRING)=CRON,START_TIME(INT64)=1744717707000,END_TIME(INT64)=0,CALENDAR_NAME(VAR_CHAR_STRING)=null,MISFIRE_INSTR(INT16)=0,JOB_DATA(BLOB)=}]]... 940 sinkTask-63==>DML[meta[monitor-stat_mq_queue_info,1778485272,UPDATE,1778482891]prev[Struct{id(INT32)=14646,tibco_alias(VAR_CHAR_STRING)=jq_pix_c,url(VAR_CHAR_STRING)=tibco-pix-i02.99bill.com:7222,name(VAR_CHAR_STRING)=bgw.mdp.RequestQueue.01040011,type(INT32)=1,static_tag(INT8)=1,product_id(VAR_CHAR_STRING)=DEFAULT,description(VAR_CHAR_STRING)=,alarm_settings(VAR_CHAR_STRING)=,on_tag(INT8)=1,receiver_count(INT32)=0,pending_msg_count(INT64)=0,pending_msg_size(INT64)=0,delivered_msg_count(INT64)=0,in_msg_rate(INT64)=0,in_bytes_rate(INT64)=0,in_total_bytes(INT64)=0,in_total_msgs(INT64)=0,out_msg_rate(INT64)=0,out_bytes_rate(INT64)=0,out_total_bytes(INT64)=0,out_total_msgs(INT64)=0,collect_time(DATETIME)=2026-05-11 15:40:00,create_time(DATETIME)=2023-08-23 13:56:01,update_time(DATETIME)=2023-08-23 13:56:01}] post[Struct{id(INT32)=14646,tibco_alias(VAR_CHAR_STRING)=jq_pix_c,url(VAR_CHAR_STRING)=tibco-pix-i02.99bill.com:7222,name(VAR_CHAR_STRING)=bgw.mdp.RequestQueue.01040011,type(INT32)=1,static_tag(INT8)=1,product_id(VAR_CHAR_STRING)=DEFAULT,description(VAR_CHAR_STRING)=,alarm_settings(VAR_CHAR_STRING)=,on_tag(INT8)=1,receiver_count(INT32)=0,pending_msg_count(INT64)=0,pending_msg_size(INT64)=0,delivered_msg_count(INT64)=0,in_msg_rate(INT64)=0,in_bytes_rate(INT64)=0,in_total_bytes(INT64)=0,in_total_msgs(INT64)=0,out_msg_rate(INT64)=0,out_bytes_rate(INT64)=0,out_total_bytes(INT64)=0,out_total_msgs(INT64)=0,collect_time(DATETIME)=2026-05-11 15:41:00,create_time(DATETIME)=2023-08-23 13:56:01,update_time(DATETIME)=2023-08-23 13:56:01}]]... 941 ] 942 [2026-05-11 17:32:16.959] [WARN] [DRC-Client-Thread] [transaction is 1018_40330734, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 943 [2026-05-11 17:32:16.960] [WARN] [DRC-Client-Thread] [transaction is 1018_40330734, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 944 [2026-05-11 17:32:16.961] [WARN] [DRC-Client-Thread] [transaction is 1018_40330734, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 945 [2026-05-11 17:32:16.962] [WARN] [DRC-Client-Thread] [transaction is 1018_40330734, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 946 [2026-05-11 17:32:16.963] [WARN] [DRC-Client-Thread] [transaction is 1018_40330734, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 947 [2026-05-11 17:32:16.964] [WARN] [DRC-Client-Thread] [transaction is 1018_40330734, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 948 [2026-05-11 17:32:16.966] [WARN] [DRC-Client-Thread] [transaction is 1018_40330734, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 949 [2026-05-11 17:32:16.967] [WARN] [DRC-Client-Thread] [transaction is 1018_40330734, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 950 [2026-05-11 17:32:16.968] [WARN] [DRC-Client-Thread] [transaction is 1018_40330734, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 951 [2026-05-11 17:32:16.969] [WARN] [DRC-Client-Thread] [transaction is 1018_40330734, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 952 [2026-05-11 17:32:16.970] [WARN] [DRC-Client-Thread] [transaction is 1018_40330734, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 953 [2026-05-11 17:32:16.971] [WARN] [DRC-Client-Thread] [transaction is 1018_40330734, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 954 [2026-05-11 17:32:16.972] [WARN] [DRC-Client-Thread] [transaction is 1018_40330734, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 955 [2026-05-11 17:32:16.972] [WARN] [DRC-Client-Thread] [transaction is 1018_40330734, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 956 [2026-05-11 17:32:16.973] [WARN] [DRC-Client-Thread] [transaction is 1018_40330734, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 957 [2026-05-11 17:32:16.974] [WARN] [DRC-Client-Thread] [transaction is 1018_40330734, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 958 [2026-05-11 17:32:16.975] [WARN] [DRC-Client-Thread] [transaction is 1018_40330734, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 959 [2026-05-11 17:32:16.976] [WARN] [DRC-Client-Thread] [transaction is 1018_40330734, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 960 [2026-05-11 17:32:16.977] [WARN] [DRC-Client-Thread] [transaction is 1018_40330734, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 961 [2026-05-11 17:32:16.978] [WARN] [DRC-Client-Thread] [transaction is 1018_40330734, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 962 [2026-05-11 17:32:16.979] [WARN] [DRC-Client-Thread] [transaction is 1018_40330734, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 963 [2026-05-11 17:32:16.980] [WARN] [DRC-Client-Thread] [transaction is 1018_40330734, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 964 [2026-05-11 17:32:16.981] [WARN] [DRC-Client-Thread] [transaction is 1018_40330734, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 965 [2026-05-11 17:32:16.982] [WARN] [DRC-Client-Thread] [transaction is 1018_40330734, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 966 [2026-05-11 17:32:16.983] [WARN] [DRC-Client-Thread] [transaction is 1018_40330734, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 967 [2026-05-11 17:32:16.984] [WARN] [DRC-Client-Thread] [transaction is 1018_40330734, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 968 [2026-05-11 17:32:16.985] [WARN] [DRC-Client-Thread] [transaction is 1018_40330734, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 969 [2026-05-11 17:32:16.986] [WARN] [DRC-Client-Thread] [transaction is 1018_40330734, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 970 [2026-05-11 17:32:16.987] [WARN] [DRC-Client-Thread] [transaction is 1018_40330734, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 971 [2026-05-11 17:32:16.988] [WARN] [DRC-Client-Thread] [transaction is 1018_40330734, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 972 [2026-05-11 17:32:16.989] [WARN] [DRC-Client-Thread] [transaction is 1018_40330734, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 973 [2026-05-11 17:32:21.448] [WARN] [DRC-Client-Thread] [transaction is 1018_40333527, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 974 [2026-05-11 17:32:21.449] [WARN] [DRC-Client-Thread] [transaction is 1018_40333527, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 975 [2026-05-11 17:32:21.450] [WARN] [DRC-Client-Thread] [transaction is 1018_40333527, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 976 [2026-05-11 17:32:21.451] [WARN] [DRC-Client-Thread] [transaction is 1018_40333527, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 977 [2026-05-11 17:32:21.452] [WARN] [DRC-Client-Thread] [transaction is 1018_40333527, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 978 [2026-05-11 17:32:21.453] [WARN] [DRC-Client-Thread] [transaction is 1018_40333527, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 979 [2026-05-11 17:32:21.454] [WARN] [DRC-Client-Thread] [transaction is 1018_40333527, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 980 [2026-05-11 17:32:21.454] [WARN] [DRC-Client-Thread] [transaction is 1018_40333527, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 981 [2026-05-11 17:32:21.455] [WARN] [DRC-Client-Thread] [transaction is 1018_40333527, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 982 [2026-05-11 17:32:21.456] [WARN] [DRC-Client-Thread] [transaction is 1018_40333527, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 983 [2026-05-11 17:32:21.457] [WARN] [DRC-Client-Thread] [transaction is 1018_40333527, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 984 [2026-05-11 17:32:21.458] [WARN] [DRC-Client-Thread] [transaction is 1018_40333527, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 985 [2026-05-11 17:32:21.459] [WARN] [DRC-Client-Thread] [transaction is 1018_40333527, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 986 [2026-05-11 17:32:21.460] [WARN] [DRC-Client-Thread] [transaction is 1018_40333527, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 987 [2026-05-11 17:32:21.461] [WARN] [DRC-Client-Thread] [transaction is 1018_40333527, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 988 [2026-05-11 17:32:21.461] [WARN] [DRC-Client-Thread] [transaction is 1018_40333527, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 989 [2026-05-11 17:32:21.462] [WARN] [DRC-Client-Thread] [transaction is 1018_40333527, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 990 [2026-05-11 17:32:21.463] [WARN] [DRC-Client-Thread] [transaction is 1018_40333527, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 991 [2026-05-11 17:32:21.464] [WARN] [DRC-Client-Thread] [transaction is 1018_40333527, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 992 [2026-05-11 17:32:21.465] [WARN] [DRC-Client-Thread] [transaction is 1018_40333527, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 993 [2026-05-11 17:32:21.466] [WARN] [DRC-Client-Thread] [transaction is 1018_40333527, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 994 [2026-05-11 17:32:21.467] [WARN] [DRC-Client-Thread] [transaction is 1018_40333527, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 995 [2026-05-11 17:32:21.467] [WARN] [DRC-Client-Thread] [transaction is 1018_40333527, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 996 [2026-05-11 17:32:21.468] [WARN] [DRC-Client-Thread] [transaction is 1018_40333527, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 997 [2026-05-11 17:32:21.469] [WARN] [DRC-Client-Thread] [transaction is 1018_40333527, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 998 [2026-05-11 17:32:21.470] [WARN] [DRC-Client-Thread] [transaction is 1018_40333527, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 999 [2026-05-11 17:32:21.471] [WARN] [DRC-Client-Thread] [transaction is 1018_40333527, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it] 1000 [2026-05-11 17:32:21.472] [WARN] [DRC-Client-Thread] [transaction is 1018_40333527, tableName is stat_mq_queue_info_history, maxRecords is 64, cut it]