1 [2025-08-25 17:09:17.671] [WARN] [main] [FrameWork exist {}] 2 java.lang.RuntimeException: java.lang.RuntimeException: Illegal format, can not read version 3 at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:93) 4 at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:31) 5 at com.oceanbase.connector.framework.threadmanager.TaskManager.start(TaskManager.java:49) 6 at com.oceanbase.oms.connector.coordinator.BootStrapPanel.boot(BootStrapPanel.java:240) 7 at com.oceanbase.oms.connector.jdbc.coordinator.Bootstrap.main(Bootstrap.java:44) 8 Caused by: java.lang.RuntimeException: Illegal format, can not read version 9 at com.pingcap.ticdc.cdc.TicdcEventDecoder.readKeyVersion(TicdcEventDecoder.java:117) 10 at com.pingcap.ticdc.cdc.TicdcEventDecoder.(TicdcEventDecoder.java:85) 11 at com.oceanbase.oms.connector.source.kafka.tidb.TiDBCdcOpenProtocolResolver.resolveCheckpoint(TiDBCdcOpenProtocolResolver.java:95) 12 at com.oceanbase.oms.connector.source.kafka.KafkaClient.getOffset(KafkaClient.java:181) 13 at com.oceanbase.oms.connector.source.kafka.KafkaClient.getAllOffset(KafkaClient.java:145) 14 at com.oceanbase.oms.connector.source.kafka.KafkaClient.init(KafkaClient.java:57) 15 at com.oceanbase.oms.connector.source.kafka.KafkaSource.initialize(KafkaSource.java:69) 16 at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:85) 17 ... 4 common frames omitted 18 Caused by: java.io.EOFException: null 19 at java.io.DataInputStream.readFully(DataInputStream.java:197) 20 at java.io.DataInputStream.readLong(DataInputStream.java:416) 21 at com.pingcap.ticdc.cdc.TicdcEventDecoder.readKeyVersion(TicdcEventDecoder.java:115) 22 ... 11 common frames omitted 23 [2025-08-25 17:09:17.676] [ERROR] [main] [main thread error] 24 java.lang.RuntimeException: java.lang.RuntimeException: Illegal format, can not read version 25 at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:93) 26 at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:31) 27 at com.oceanbase.connector.framework.threadmanager.TaskManager.start(TaskManager.java:49) 28 at com.oceanbase.oms.connector.coordinator.BootStrapPanel.boot(BootStrapPanel.java:240) 29 at com.oceanbase.oms.connector.jdbc.coordinator.Bootstrap.main(Bootstrap.java:44) 30 Caused by: java.lang.RuntimeException: Illegal format, can not read version 31 at com.pingcap.ticdc.cdc.TicdcEventDecoder.readKeyVersion(TicdcEventDecoder.java:117) 32 at com.pingcap.ticdc.cdc.TicdcEventDecoder.(TicdcEventDecoder.java:85) 33 at com.oceanbase.oms.connector.source.kafka.tidb.TiDBCdcOpenProtocolResolver.resolveCheckpoint(TiDBCdcOpenProtocolResolver.java:95) 34 at com.oceanbase.oms.connector.source.kafka.KafkaClient.getOffset(KafkaClient.java:181) 35 at com.oceanbase.oms.connector.source.kafka.KafkaClient.getAllOffset(KafkaClient.java:145) 36 at com.oceanbase.oms.connector.source.kafka.KafkaClient.init(KafkaClient.java:57) 37 at com.oceanbase.oms.connector.source.kafka.KafkaSource.initialize(KafkaSource.java:69) 38 at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:85) 39 ... 4 common frames omitted 40 Caused by: java.io.EOFException: null 41 at java.io.DataInputStream.readFully(DataInputStream.java:197) 42 at java.io.DataInputStream.readLong(DataInputStream.java:416) 43 at com.pingcap.ticdc.cdc.TicdcEventDecoder.readKeyVersion(TicdcEventDecoder.java:115) 44 ... 11 common frames omitted 45 [2025-08-25 17:11:03.327] [INFO] [main] [NativeFSLock: acquire with pid [3204514]] 46 [2025-08-25 17:11:03.330] [INFO] [main] [error file not exists] 47 [2025-08-25 17:11:03.346] [INFO] [main] [system default timezone : GMT+08:00] 48 [2025-08-25 17:11:03.492] [INFO] [main] [build condition cache, caseInsensitive: false, condition : { 49 "DefaultConnectorCondition" : { 50 "blackCondition" : "[{\"all\":false,\"sub\":[{\"func\":\"fn\",\"name\":\"ds_ele_benchmark_billaccount\"},{\"func\":\"fn\",\"name\":\"ds_ele_benchmark_billaccount_month\"},{\"func\":\"fn\",\"name\":\"drc_txn*\"},{\"func\":\"fn\",\"name\":\"DRC_TXN*\"},{\"func\":\"fn\",\"name\":\"delay_delete_*\"},{\"func\":\"fn\",\"name\":\"DELAY_DELETE_*\"}],\"func\":\"fn\",\"name\":\"ncms_xz\",\"map\":\"ncms_xz\"}]", 51 "whiteCondition" : "[{\"all\":false,\"sub\":[{\"func\":\"fn\",\"name\":\"*benchmark_billaccount\"},{\"func\":\"fn\",\"name\":\"*benchmark_billaccount_month\"},{\"func\":\"fn\",\"name\":\"*_export\"},{\"name\":\"ocr_elemeter\",\"map\":\"ocr_elemeter_tidb\"},{\"name\":\"tele_benchmark_billaccount\",\"map\":\"tele_benchmark_billaccount_tidb\"},{\"name\":\"tele_benchmark_billaccount_month\",\"map\":\"tele_benchmark_billaccount_month_tidb\"},{\"name\":\"tele_payment_details_export\",\"map\":\"tele_payment_details_export_tidb\"},{\"name\":\"ele_benchmark_billaccount_month\",\"map\":\"ele_benchmark_billaccount_month_tidb\"},{\"name\":\"ele_benchmark_billaccount\",\"map\":\"ele_benchmark_billaccount_tidb\"},{\"name\":\"tele_other_amount_finance_export\",\"map\":\"tele_other_amount_finance_export_tidb\"},{\"name\":\"ele_other_amount_finance_export\",\"map\":\"ele_other_amount_finance_export_tidb\"}],\"func\":\"fn\",\"name\":\"ncms_xz\",\"map\":\"ncms_xz\"}]" 52 } 53 }] 54 [2025-08-25 17:11:03.512] [INFO] [main] [map source class [com.oceanbase.oms.connector.source.kafka.KafkaSourceBooster] to [com.oceanbase.oms.connector.source.kafka.KafkaSourceBooster]] 55 [2025-08-25 17:11:03.514] [INFO] [main] [map sink class [com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSinkBooster] to [com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSinkBooster]] 56 [2025-08-25 17:11:03.521] [WARN] [main] [MySQL not determinate utf8mb4 support or not] 57 [2025-08-25 17:11:03.521] [WARN] [main] [MySQL not determinate utf8mb4 support or not] 58 [2025-08-25 17:11:03.549] [INFO] [main] [auto set coordinator config: {bridgeQueueSize=64, throttleMemoryBound=1073741824} by metrics MID] 59 [2025-08-25 17:11:03.567] [INFO] [main] [CastConfig: com.oceanbase.oms.connector.common.cast.CastConfig@6989da5e] 60 [2025-08-25 17:11:03.579] [INFO] [main] [[condition]] 61 [2025-08-25 17:11:03.583] [INFO] [main] [ blackCondition = [{"all":false,"sub":[{"func":"fn","name":"ds_ele_benchmark_billaccount"},{"func":"fn","name":"ds_ele_benchmark_billaccount_month"},{"func":"fn","name":"drc_txn*"},{"func":"fn","name":"DRC_TXN*"},{"func":"fn","name":"delay_delete_*"},{"func":"fn","name":"DELAY_DELETE_*"}],"func":"fn","name":"ncms_xz","map":"ncms_xz"}]] 62 [2025-08-25 17:11:03.583] [INFO] [main] [ whiteCondition = [{"all":false,"sub":[{"func":"fn","name":"*benchmark_billaccount"},{"func":"fn","name":"*benchmark_billaccount_month"},{"func":"fn","name":"*_export"},{"name":"ocr_elemeter","map":"ocr_elemeter_tidb"},{"name":"tele_benchmark_billaccount","map":"tele_benchmark_billaccount_tidb"},{"name":"tele_benchmark_billaccount_month","map":"tele_benchmark_billaccount_month_tidb"},{"name":"tele_payment_details_export","map":"tele_payment_details_export_tidb"},{"name":"ele_benchmark_billaccount_month","map":"ele_benchmark_billaccount_month_tidb"},{"name":"ele_benchmark_billaccount","map":"ele_benchmark_billaccount_tidb"},{"name":"tele_other_amount_finance_export","map":"tele_other_amount_finance_export_tidb"},{"name":"ele_other_amount_finance_export","map":"ele_other_amount_finance_export_tidb"}],"func":"fn","name":"ncms_xz","map":"ncms_xz"}]] 63 [2025-08-25 17:11:03.583] [INFO] [main] [[coordinator]] 64 [2025-08-25 17:11:03.584] [INFO] [main] [ taskIdentity = np_70tg6g6fuekg] 65 [2025-08-25 17:11:03.584] [INFO] [main] [ enableOmsConnectorV2Report = true] 66 [2025-08-25 17:11:03.584] [INFO] [main] [ isCaseSensitive = true] 67 [2025-08-25 17:11:03.584] [INFO] [main] [ dbTableCaseStrategy = follow-source] 68 [2025-08-25 17:11:03.584] [INFO] [main] [ streamMode = true] 69 [2025-08-25 17:11:03.584] [INFO] [main] [ timezone = +08:00] 70 [2025-08-25 17:11:03.584] [INFO] [main] [ enableActiveReportTask = false] 71 [2025-08-25 17:11:03.584] [INFO] [main] [ bridgeQueueSize = 64] 72 [2025-08-25 17:11:03.584] [INFO] [main] [ mysqlVersion = 7.1.0] 73 [2025-08-25 17:11:03.584] [INFO] [main] [ enableMetricReportTask = false] 74 [2025-08-25 17:11:03.584] [INFO] [main] [ sourceType = MYSQL] 75 [2025-08-25 17:11:03.584] [INFO] [main] [ columnCaseStrategy = follow-source] 76 [2025-08-25 17:11:03.584] [INFO] [main] [ mysqlExplicitDefaultsForTimestamp = ON] 77 [2025-08-25 17:11:03.584] [INFO] [main] [ throttleMemoryBound = 1073741824] 78 [2025-08-25 17:11:03.584] [INFO] [main] [ sinkType = OB_MYSQL] 79 [2025-08-25 17:11:03.584] [INFO] [main] [ listenPort = 16000] 80 [2025-08-25 17:11:03.584] [INFO] [main] [ allowRecordTypes = DELETE,INSERT,UPDATE] 81 [2025-08-25 17:11:03.584] [INFO] [main] [ ignoreCompensateDDL = false] 82 [2025-08-25 17:11:03.584] [INFO] [main] [ connectorJvmParam = -Xms4096m -Xmx4096m -Xmn2048m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=128m -XX:+UseConcMarkSweepGC -XX:+UseParNewGC -XX:+CMSParallelRemarkEnabled -XX:+UseCMSInitiatingOccupancyOnly -XX:CMSInitiatingOccupancyFraction=70 -XX:+CMSClassUnloadingEnabled] 83 [2025-08-25 17:11:03.584] [INFO] [main] [[sink]] 84 [2025-08-25 17:11:03.584] [INFO] [main] [ boosterClass = com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSinkBooster] 85 [2025-08-25 17:11:03.584] [INFO] [main] [ enableNoUniqueConstraintTableReplicate = false] 86 [2025-08-25 17:11:03.584] [INFO] [main] [ dbTableCaseStrategy = follow-source] 87 [2025-08-25 17:11:03.584] [INFO] [main] [ dbVersion = 4.3.2.1] 88 [2025-08-25 17:11:03.584] [INFO] [main] [ endpointId = e_70beg7377y9s] 89 [2025-08-25 17:11:03.584] [INFO] [main] [ timezone = +08:00] 90 [2025-08-25 17:11:03.585] [INFO] [main] [ filterHiddenPK = false] 91 [2025-08-25 17:11:03.585] [INFO] [main] [ isPreLoadAllTableSchema = false] 92 [2025-08-25 17:11:03.585] [INFO] [main] [ type = JDBC_SINK_OB_MYSQL] 93 [2025-08-25 17:11:03.585] [INFO] [main] [ insertMode = INSERT] 94 [2025-08-25 17:11:03.585] [INFO] [main] [ password = Cmiot.ncms@123] 95 [2025-08-25 17:11:03.585] [INFO] [main] [ charsetReplaceMap = {}] 96 [2025-08-25 17:11:03.585] [INFO] [main] [ sourceType = TIDB] 97 [2025-08-25 17:11:03.585] [INFO] [main] [ columnCaseStrategy = follow-source] 98 [2025-08-25 17:11:03.585] [INFO] [main] [ jdbcUrl = jdbc:mysql://10.252.210.192:2883?useUnicode=true&allowMultiQueries=true&socketTimeout=50000&characterEncoding=utf8&readOnlyPropagatesToServer=false] 99 [2025-08-25 17:11:03.585] [INFO] [main] [ sinkMaps = [["ncms_xz","ele_other_amount_finance_export_tidb"],["ncms_xz","tele_other_amount_finance_export_tidb"],["ncms_xz","ele_benchmark_billaccount_tidb"],["ncms_xz","tele_benchmark_billaccount_month_tidb"],["ncms_xz","tele_payment_details_export_tidb"],["ncms_xz","ele_benchmark_billaccount_month_tidb"],["ncms_xz","tele_benchmark_billaccount_tidb"],["ncms_xz","ocr_elemeter_tidb"]]] 100 [2025-08-25 17:11:03.585] [INFO] [main] [ ignoreRedunantColumnsReplicate = false] 101 [2025-08-25 17:11:03.585] [INFO] [main] [ conflictTargetSchema = true] 102 [2025-08-25 17:11:03.585] [INFO] [main] [ jar = jdbc-sink-ob-mysql.jar] 103 [2025-08-25 17:11:03.585] [INFO] [main] [ workerNum = 4] 104 [2025-08-25 17:11:03.585] [INFO] [main] [ sinkType = OB_MYSQL] 105 [2025-08-25 17:11:03.585] [INFO] [main] [ tenant = ncms_xz] 106 [2025-08-25 17:11:03.585] [INFO] [main] [ username = fcncms@ncms_xz#ob_pro] 107 [2025-08-25 17:11:03.585] [INFO] [main] [[source]] 108 [2025-08-25 17:11:03.585] [INFO] [main] [ checkpoint = {"oms":"1756111699"}] 109 [2025-08-25 17:11:03.585] [INFO] [main] [ boosterClass = com.oceanbase.oms.connector.source.kafka.KafkaSourceBooster] 110 [2025-08-25 17:11:03.585] [INFO] [main] [ taskIdentity = np_70tg6g6fuekg] 111 [2025-08-25 17:11:03.585] [INFO] [main] [ enableOmsConnectorV2Report = true] 112 [2025-08-25 17:11:03.585] [INFO] [main] [ kafkaAddr = 10.252.158.60] 113 [2025-08-25 17:11:03.585] [INFO] [main] [ enableNoUniqueConstraintTableReplicate = false] 114 [2025-08-25 17:11:03.585] [INFO] [main] [ kafkaTopic = oms] 115 [2025-08-25 17:11:03.585] [INFO] [main] [ timezone = +08:00] 116 [2025-08-25 17:11:03.585] [INFO] [main] [ taskSubId = 1] 117 [2025-08-25 17:11:03.586] [INFO] [main] [ dbType = TIDB] 118 [2025-08-25 17:11:03.586] [INFO] [main] [ type = KAFKA_SOURCE] 119 [2025-08-25 17:11:03.586] [INFO] [main] [ taskType = migrate] 120 [2025-08-25 17:11:03.586] [INFO] [main] [ securityProtocol = PLAINTEXT] 121 [2025-08-25 17:11:03.586] [INFO] [main] [ kafkaServer = 10.252.158.60:9092,10.252.158.59:9092,10.252.158.57:9092] 122 [2025-08-25 17:11:03.586] [INFO] [main] [ jar = connector-source-kafka.jar] 123 [2025-08-25 17:11:03.586] [INFO] [main] [ kafkaPort = 9092] 124 [2025-08-25 17:11:03.586] [INFO] [main] [ properties = {}] 125 [2025-08-25 17:11:03.891] [INFO] [main] [[Init DruidDataSource]sessionParameters: {}] 126 [2025-08-25 17:11:03.893] [INFO] [main] [10.252.210.192:2883 fcncms@ncms_xz#ob_pro init sql:set foreign_key_checks = off] 127 [2025-08-25 17:11:03.894] [INFO] [main] [init druid dataSource with loginTimeout[300], maxWaitMillis[12000], maxActive[4], initActive[4], minIdle[4]] 128 [2025-08-25 17:11:03.894] [INFO] [main] [connect with url [jdbc:mysql://10.252.210.192:2883?readOnlyPropagatesToServer=false&useUnicode=true&rewriteBatchedStatements=true&socketTimeout=50000&connectTimeout=30000&allowMultiQueries=true&characterEncoding=utf8&netTimeoutForStreamingResults=28800&useSSL=false]] 129 [2025-08-25 17:11:03.894] [INFO] [main] [[SET TIME_ZONE='+08:00', set foreign_key_checks = off, set sql_mode='NO_AUTO_VALUE_ON_ZERO', set session sql_select_limit=9223372036854775807] for instance 10.252.210.192:2883 user fcncms@ncms_xz#ob_pro characterSet ] 130 [2025-08-25 17:11:03.908] [INFO] [main] [[Init DruidDataSource]sessionParameters: {}] 131 [2025-08-25 17:11:03.908] [INFO] [main] [10.252.210.192:2883 fcncms@ncms_xz#ob_pro init sql:set foreign_key_checks = off] 132 [2025-08-25 17:11:03.908] [INFO] [main] [init druid dataSource with loginTimeout[300], maxWaitMillis[12000], maxActive[3], initActive[0], minIdle[0]] 133 [2025-08-25 17:11:03.908] [INFO] [main] [connect with url [jdbc:mysql://10.252.210.192:2883?readOnlyPropagatesToServer=false&useUnicode=true&rewriteBatchedStatements=true&socketTimeout=172800000&connectTimeout=30000&allowMultiQueries=true&characterEncoding=utf8&netTimeoutForStreamingResults=28800&useSSL=false]] 134 [2025-08-25 17:11:03.908] [INFO] [main] [[SET TIME_ZONE='+08:00', set foreign_key_checks = off, set sql_mode='NO_AUTO_VALUE_ON_ZERO', set session sql_select_limit=9223372036854775807] for instance 10.252.210.192:2883 user fcncms@ncms_xz#ob_pro characterSet ] 135 [2025-08-25 17:11:04.072] [INFO] [main] [{dataSource-1} inited] 136 [2025-08-25 17:11:04.256] [INFO] [main] [SHOW VARIABLES LIKE 'version_comment'] 137 [2025-08-25 17:11:04.260] [INFO] [main] [sink db version:4.3.2.1] 138 [2025-08-25 17:11:04.371] [INFO] [main] [Inited OBHighWatermarkMonitor. querySql. [OB_MYSQL], cpuSQL: select /*+query_timeout(5000000)*/ 100 - max(round(memstore_used/memstore_limit*100)) from oceanbase.GV$OB_MEMSTORE, memSQL: select /*+query_timeout(5000000)*/ 100 - max(round(memstore_used/memstore_limit*100)) from oceanbase.GV$OB_MEMSTORE] 139 [2025-08-25 17:11:04.380] [INFO] [main] [put coordinator.maxRecordCapacity: batchSize(128), workerNum(4), maxRecordCapacity: 16384, may have been set, so it's inconsistent with cal value ] 140 [2025-08-25 17:11:04.430] [WARN] [main] [MySQL not determinate utf8mb4 support or not] 141 [2025-08-25 17:11:04.442] [INFO] [main] [[Init DruidDataSource]sessionParameters: {}] 142 [2025-08-25 17:11:04.442] [INFO] [main] [10.252.210.192:2883 fcncms@ncms_xz#ob_pro init sql:set foreign_key_checks = off] 143 [2025-08-25 17:11:04.442] [INFO] [main] [init druid dataSource with loginTimeout[300], maxWaitMillis[12000], maxActive[3], initActive[0], minIdle[0]] 144 [2025-08-25 17:11:04.443] [INFO] [main] [connect with url [jdbc:mysql://10.252.210.192:2883?readOnlyPropagatesToServer=false&useUnicode=true&rewriteBatchedStatements=true&socketTimeout=1800000&connectTimeout=30000&allowMultiQueries=true&characterEncoding=utf8&netTimeoutForStreamingResults=28800&useSSL=false]] 145 [2025-08-25 17:11:04.443] [INFO] [main] [[SET TIME_ZONE='+00:00', set foreign_key_checks = off, set sql_mode='NO_AUTO_VALUE_ON_ZERO', set session sql_select_limit=9223372036854775807] for instance 10.252.210.192:2883 user fcncms@ncms_xz#ob_pro characterSet utf8] 146 [2025-08-25 17:11:04.443] [INFO] [main] [create jdbc:mysql://10.252.210.192:2883?useUnicode=true&allowMultiQueries=true&socketTimeout=50000&characterEncoding=utf8&readOnlyPropagatesToServer=false|fcncms@ncms_xz#ob_pro|UTF8|default data source success , charset : utf8 , sql timeout : 1800000 , {sql_select_limit=9223372036854775807, timezone=+08:00}] 147 [2025-08-25 17:11:04.443] [INFO] [main] [init datasource success : jdbc:mysql://10.252.210.192:2883?useUnicode=true&allowMultiQueries=true&socketTimeout=50000&characterEncoding=utf8&readOnlyPropagatesToServer=false] 148 [2025-08-25 17:11:04.465] [INFO] [main] [ConcurrentArrayQueue mod MULTI_PRODUCER_MULTI_CONSUMER, size: 64] 149 [2025-08-25 17:11:04.469] [INFO] [main] [ConcurrentArrayQueue mod MULTI_PRODUCER_MULTI_CONSUMER, size: 64] 150 [2025-08-25 17:11:04.480] [INFO] [main] [[condition]] 151 [2025-08-25 17:11:04.480] [INFO] [main] [ blackCondition = [{"all":false,"sub":[{"func":"fn","name":"ds_ele_benchmark_billaccount"},{"func":"fn","name":"ds_ele_benchmark_billaccount_month"},{"func":"fn","name":"drc_txn*"},{"func":"fn","name":"DRC_TXN*"},{"func":"fn","name":"delay_delete_*"},{"func":"fn","name":"DELAY_DELETE_*"}],"func":"fn","name":"ncms_xz","map":"ncms_xz"}]] 152 [2025-08-25 17:11:04.480] [INFO] [main] [ whiteCondition = [{"all":false,"sub":[{"func":"fn","name":"*benchmark_billaccount"},{"func":"fn","name":"*benchmark_billaccount_month"},{"func":"fn","name":"*_export"},{"name":"ocr_elemeter","map":"ocr_elemeter_tidb"},{"name":"tele_benchmark_billaccount","map":"tele_benchmark_billaccount_tidb"},{"name":"tele_benchmark_billaccount_month","map":"tele_benchmark_billaccount_month_tidb"},{"name":"tele_payment_details_export","map":"tele_payment_details_export_tidb"},{"name":"ele_benchmark_billaccount_month","map":"ele_benchmark_billaccount_month_tidb"},{"name":"ele_benchmark_billaccount","map":"ele_benchmark_billaccount_tidb"},{"name":"tele_other_amount_finance_export","map":"tele_other_amount_finance_export_tidb"},{"name":"ele_other_amount_finance_export","map":"ele_other_amount_finance_export_tidb"}],"func":"fn","name":"ncms_xz","map":"ncms_xz"}]] 153 [2025-08-25 17:11:04.480] [INFO] [main] [[coordinator]] 154 [2025-08-25 17:11:04.480] [INFO] [main] [ taskIdentity = np_70tg6g6fuekg] 155 [2025-08-25 17:11:04.480] [INFO] [main] [ enableOmsConnectorV2Report = true] 156 [2025-08-25 17:11:04.480] [INFO] [main] [ isCaseSensitive = true] 157 [2025-08-25 17:11:04.480] [INFO] [main] [ dbTableCaseStrategy = follow-source] 158 [2025-08-25 17:11:04.480] [INFO] [main] [ streamMode = true] 159 [2025-08-25 17:11:04.480] [INFO] [main] [ maxRecordCapacity = 16384] 160 [2025-08-25 17:11:04.481] [INFO] [main] [ timezone = +08:00] 161 [2025-08-25 17:11:04.481] [INFO] [main] [ enableActiveReportTask = false] 162 [2025-08-25 17:11:04.481] [INFO] [main] [ bridgeQueueSize = 64] 163 [2025-08-25 17:11:04.481] [INFO] [main] [ mysqlVersion = 7.1.0] 164 [2025-08-25 17:11:04.481] [INFO] [main] [ enableMetricReportTask = false] 165 [2025-08-25 17:11:04.481] [INFO] [main] [ sourceType = MYSQL] 166 [2025-08-25 17:11:04.481] [INFO] [main] [ columnCaseStrategy = follow-source] 167 [2025-08-25 17:11:04.481] [INFO] [main] [ mysqlExplicitDefaultsForTimestamp = ON] 168 [2025-08-25 17:11:04.481] [INFO] [main] [ throttleMemoryBound = 1073741824] 169 [2025-08-25 17:11:04.481] [INFO] [main] [ sinkType = OB_MYSQL] 170 [2025-08-25 17:11:04.481] [INFO] [main] [ dispatcherClassName = com.oceanbase.oms.connector.dispatcher.scheduler.DefaultTransactionScheduler] 171 [2025-08-25 17:11:04.481] [INFO] [main] [ listenPort = 16000] 172 [2025-08-25 17:11:04.481] [INFO] [main] [ allowRecordTypes = DELETE,INSERT,UPDATE] 173 [2025-08-25 17:11:04.481] [INFO] [main] [ ignoreCompensateDDL = false] 174 [2025-08-25 17:11:04.481] [INFO] [main] [ connectorJvmParam = -Xms4096m -Xmx4096m -Xmn2048m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=128m -XX:+UseConcMarkSweepGC -XX:+UseParNewGC -XX:+CMSParallelRemarkEnabled -XX:+UseCMSInitiatingOccupancyOnly -XX:CMSInitiatingOccupancyFraction=70 -XX:+CMSClassUnloadingEnabled] 175 [2025-08-25 17:11:04.481] [INFO] [main] [[sink]] 176 [2025-08-25 17:11:04.481] [INFO] [main] [ boosterClass = com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSinkBooster] 177 [2025-08-25 17:11:04.481] [INFO] [main] [ timezone = +08:00] 178 [2025-08-25 17:11:04.481] [INFO] [main] [ filterHiddenPK = false] 179 [2025-08-25 17:11:04.481] [INFO] [main] [ isPreLoadAllTableSchema = false] 180 [2025-08-25 17:11:04.481] [INFO] [main] [ type = JDBC_SINK_OB_MYSQL] 181 [2025-08-25 17:11:04.481] [INFO] [main] [ password = Cmiot.ncms@123] 182 [2025-08-25 17:11:04.481] [INFO] [main] [ columnCaseStrategy = follow-source] 183 [2025-08-25 17:11:04.481] [INFO] [main] [ sinkMaps = [["ncms_xz","ele_other_amount_finance_export_tidb"],["ncms_xz","tele_other_amount_finance_export_tidb"],["ncms_xz","ele_benchmark_billaccount_tidb"],["ncms_xz","tele_benchmark_billaccount_month_tidb"],["ncms_xz","tele_payment_details_export_tidb"],["ncms_xz","ele_benchmark_billaccount_month_tidb"],["ncms_xz","tele_benchmark_billaccount_tidb"],["ncms_xz","ocr_elemeter_tidb"]]] 184 [2025-08-25 17:11:04.481] [INFO] [main] [ conflictTargetSchema = true] 185 [2025-08-25 17:11:04.481] [INFO] [main] [ jar = jdbc-sink-ob-mysql.jar] 186 [2025-08-25 17:11:04.481] [INFO] [main] [ enableTransactionWriter = true] 187 [2025-08-25 17:11:04.481] [INFO] [main] [ supportedTimezone = []] 188 [2025-08-25 17:11:04.481] [INFO] [main] [ tenant = ncms_xz] 189 [2025-08-25 17:11:04.481] [INFO] [main] [ enableNoUniqueConstraintTableReplicate = false] 190 [2025-08-25 17:11:04.481] [INFO] [main] [ dbTableCaseStrategy = follow-source] 191 [2025-08-25 17:11:04.481] [INFO] [main] [ dbVersion = 4.3.2.1] 192 [2025-08-25 17:11:04.481] [INFO] [main] [ endpointId = e_70beg7377y9s] 193 [2025-08-25 17:11:04.481] [INFO] [main] [ insertMode = INSERT] 194 [2025-08-25 17:11:04.481] [INFO] [main] [ charsetReplaceMap = {}] 195 [2025-08-25 17:11:04.481] [INFO] [main] [ sourceType = TIDB] 196 [2025-08-25 17:11:04.481] [INFO] [main] [ jdbcUrl = jdbc:mysql://10.252.210.192:2883?useUnicode=true&allowMultiQueries=true&socketTimeout=50000&characterEncoding=utf8&readOnlyPropagatesToServer=false] 197 [2025-08-25 17:11:04.481] [INFO] [main] [ ignoreRedunantColumnsReplicate = false] 198 [2025-08-25 17:11:04.481] [INFO] [main] [ workerNum = 4] 199 [2025-08-25 17:11:04.482] [INFO] [main] [ sinkType = OB_MYSQL] 200 [2025-08-25 17:11:04.482] [INFO] [main] [ username = fcncms@ncms_xz#ob_pro] 201 [2025-08-25 17:11:04.482] [INFO] [main] [[source]] 202 [2025-08-25 17:11:04.482] [INFO] [main] [ checkpoint = {"oms":"1756111699"}] 203 [2025-08-25 17:11:04.482] [INFO] [main] [ boosterClass = com.oceanbase.oms.connector.source.kafka.KafkaSourceBooster] 204 [2025-08-25 17:11:04.482] [INFO] [main] [ taskIdentity = np_70tg6g6fuekg] 205 [2025-08-25 17:11:04.482] [INFO] [main] [ enableOmsConnectorV2Report = true] 206 [2025-08-25 17:11:04.482] [INFO] [main] [ kafkaAddr = 10.252.158.60] 207 [2025-08-25 17:11:04.482] [INFO] [main] [ enableNoUniqueConstraintTableReplicate = false] 208 [2025-08-25 17:11:04.482] [INFO] [main] [ kafkaTopic = oms] 209 [2025-08-25 17:11:04.482] [INFO] [main] [ timezone = +08:00] 210 [2025-08-25 17:11:04.482] [INFO] [main] [ taskSubId = 1] 211 [2025-08-25 17:11:04.482] [INFO] [main] [ dbType = TIDB] 212 [2025-08-25 17:11:04.482] [INFO] [main] [ type = KAFKA_SOURCE] 213 [2025-08-25 17:11:04.482] [INFO] [main] [ taskType = migrate] 214 [2025-08-25 17:11:04.482] [INFO] [main] [ securityProtocol = PLAINTEXT] 215 [2025-08-25 17:11:04.482] [INFO] [main] [ kafkaServer = 10.252.158.60:9092,10.252.158.59:9092,10.252.158.57:9092] 216 [2025-08-25 17:11:04.482] [INFO] [main] [ jar = connector-source-kafka.jar] 217 [2025-08-25 17:11:04.482] [INFO] [main] [ kafkaPort = 9092] 218 [2025-08-25 17:11:04.482] [INFO] [main] [ properties = {}] 219 [2025-08-25 17:11:04.486] [INFO] [main] [BootStrap: init memoryBoound value to 1073741824] 220 [2025-08-25 17:11:04.491] [INFO] [main] [BootStrapPanel: register keep alive url [/status]] 221 [2025-08-25 17:11:04.492] [INFO] [main] [BootStrapPanel: register source stats url [/source/stats]] 222 [2025-08-25 17:11:04.492] [INFO] [main] [BootStrapPanel: register checkpoint query url [/checkpoint/query]] 223 [2025-08-25 17:11:04.493] [INFO] [main] [BootStrapPanel: register throttle control url [/throttle/control]] 224 [2025-08-25 17:11:04.494] [INFO] [main] [BootStrapPanel: register throttle query url [/throttle/query]] 225 [2025-08-25 17:11:04.511] [INFO] [main] [Writer init with arguments, write mode[SEMI_BATCH_PREPARE_STATEMENT], maxTxnRetryTimes[1000], retryIntervalTime[1000],dryRun[false], printSql[false], slowSqlThreshold[15], ignoreDDL[true], hotKeyMerge[false]typeStatistics[false], fullBatchWithSameTable[false], canLobBatched[true]] 226 [2025-08-25 17:11:04.512] [INFO] [main] [Writer init with arguments, write mode[SEMI_BATCH_PREPARE_STATEMENT], maxTxnRetryTimes[1000], retryIntervalTime[1000],dryRun[false], printSql[false], slowSqlThreshold[15], ignoreDDL[true], hotKeyMerge[false]typeStatistics[false], fullBatchWithSameTable[false], canLobBatched[true]] 227 [2025-08-25 17:11:04.513] [INFO] [main] [Writer init with arguments, write mode[SEMI_BATCH_PREPARE_STATEMENT], maxTxnRetryTimes[1000], retryIntervalTime[1000],dryRun[false], printSql[false], slowSqlThreshold[15], ignoreDDL[true], hotKeyMerge[false]typeStatistics[false], fullBatchWithSameTable[false], canLobBatched[true]] 228 [2025-08-25 17:11:04.513] [INFO] [main] [Writer init with arguments, write mode[SEMI_BATCH_PREPARE_STATEMENT], maxTxnRetryTimes[1000], retryIntervalTime[1000],dryRun[false], printSql[false], slowSqlThreshold[15], ignoreDDL[true], hotKeyMerge[false]typeStatistics[false], fullBatchWithSameTable[false], canLobBatched[true]] 229 [2025-08-25 17:11:04.520] [INFO] [main] [KafkaConsumer properties: {security.protocol=PLAINTEXT, enable.auto.commit=true, max.poll.records=100, value.deserializer=org.apache.kafka.common.serialization.ByteArrayDeserializer, group.id=oms_jdbc_connector_null, request.timeout.ms=300000, session.timeout.ms=80000, bootstrap.servers=10.252.158.60:9092,10.252.158.59:9092,10.252.158.57:9092, max.partition.fetch.bytes=4388608, max.poll.interval.ms=120000, heartbeat.interval.ms=60000, key.deserializer=org.apache.kafka.common.serialization.ByteArrayDeserializer, auto.commit.interval.ms=1000}] 230 [2025-08-25 17:11:04.546] [INFO] [main] [ConsumerConfig values: 231 allow.auto.create.topics = true 232 auto.commit.interval.ms = 1000 233 auto.include.jmx.reporter = true 234 auto.offset.reset = latest 235 bootstrap.servers = [10.252.158.60:9092, 10.252.158.59:9092, 10.252.158.57:9092] 236 check.crcs = true 237 client.dns.lookup = use_all_dns_ips 238 client.id = consumer-oms_jdbc_connector_null-1 239 client.rack = 240 connections.max.idle.ms = 540000 241 default.api.timeout.ms = 60000 242 enable.auto.commit = true 243 exclude.internal.topics = true 244 fetch.max.bytes = 52428800 245 fetch.max.wait.ms = 500 246 fetch.min.bytes = 1 247 group.id = oms_jdbc_connector_null 248 group.instance.id = null 249 heartbeat.interval.ms = 60000 250 interceptor.classes = [] 251 internal.leave.group.on.close = true 252 internal.throw.on.fetch.stable.offset.unsupported = false 253 isolation.level = read_uncommitted 254 key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer 255 max.partition.fetch.bytes = 4388608 256 max.poll.interval.ms = 120000 257 max.poll.records = 100 258 metadata.max.age.ms = 300000 259 metric.reporters = [] 260 metrics.num.samples = 2 261 metrics.recording.level = INFO 262 metrics.sample.window.ms = 30000 263 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor] 264 receive.buffer.bytes = 65536 265 reconnect.backoff.max.ms = 1000 266 reconnect.backoff.ms = 50 267 request.timeout.ms = 300000 268 retry.backoff.ms = 100 269 sasl.client.callback.handler.class = null 270 sasl.jaas.config = null 271 sasl.kerberos.kinit.cmd = /usr/bin/kinit 272 sasl.kerberos.min.time.before.relogin = 60000 273 sasl.kerberos.service.name = null 274 sasl.kerberos.ticket.renew.jitter = 0.05 275 sasl.kerberos.ticket.renew.window.factor = 0.8 276 sasl.login.callback.handler.class = null 277 sasl.login.class = null 278 sasl.login.connect.timeout.ms = null 279 sasl.login.read.timeout.ms = null 280 sasl.login.refresh.buffer.seconds = 300 281 sasl.login.refresh.min.period.seconds = 60 282 sasl.login.refresh.window.factor = 0.8 283 sasl.login.refresh.window.jitter = 0.05 284 sasl.login.retry.backoff.max.ms = 10000 285 sasl.login.retry.backoff.ms = 100 286 sasl.mechanism = GSSAPI 287 sasl.oauthbearer.clock.skew.seconds = 30 288 sasl.oauthbearer.expected.audience = null 289 sasl.oauthbearer.expected.issuer = null 290 sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 291 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 292 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 293 sasl.oauthbearer.jwks.endpoint.url = null 294 sasl.oauthbearer.scope.claim.name = scope 295 sasl.oauthbearer.sub.claim.name = sub 296 sasl.oauthbearer.token.endpoint.url = null 297 security.protocol = PLAINTEXT 298 security.providers = null 299 send.buffer.bytes = 131072 300 session.timeout.ms = 80000 301 socket.connection.setup.timeout.max.ms = 30000 302 socket.connection.setup.timeout.ms = 10000 303 ssl.cipher.suites = null 304 ssl.enabled.protocols = [TLSv1.2] 305 ssl.endpoint.identification.algorithm = https 306 ssl.engine.factory.class = null 307 ssl.key.password = null 308 ssl.keymanager.algorithm = SunX509 309 ssl.keystore.certificate.chain = null 310 ssl.keystore.key = null 311 ssl.keystore.location = null 312 ssl.keystore.password = null 313 ssl.keystore.type = JKS 314 ssl.protocol = TLSv1.2 315 ssl.provider = null 316 ssl.secure.random.implementation = null 317 ssl.trustmanager.algorithm = PKIX 318 ssl.truststore.certificates = null 319 ssl.truststore.location = null 320 ssl.truststore.password = null 321 ssl.truststore.type = JKS 322 value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer 323 ] 324 [2025-08-25 17:11:04.625] [INFO] [main] [Kafka version: 3.4.0] 325 [2025-08-25 17:11:04.625] [INFO] [main] [Kafka commitId: 2e1947d240607d53] 326 [2025-08-25 17:11:04.625] [INFO] [main] [Kafka startTimeMs: 1756113064624] 327 [2025-08-25 17:11:04.948] [INFO] [main] [[Consumer clientId=consumer-oms_jdbc_connector_null-1, groupId=oms_jdbc_connector_null] Cluster ID: SqQYmotJTjOK9QK5duAA9g] 328 [2025-08-25 17:11:04.951] [INFO] [main] [KafkaConsumer properties: {security.protocol=PLAINTEXT, enable.auto.commit=true, max.poll.records=100, value.deserializer=org.apache.kafka.common.serialization.ByteArrayDeserializer, group.id=oms_jdbc_connector_null, request.timeout.ms=300000, session.timeout.ms=80000, bootstrap.servers=10.252.158.60:9092,10.252.158.59:9092,10.252.158.57:9092, max.partition.fetch.bytes=4388608, max.poll.interval.ms=120000, heartbeat.interval.ms=60000, key.deserializer=org.apache.kafka.common.serialization.ByteArrayDeserializer, auto.commit.interval.ms=1000}] 329 [2025-08-25 17:11:04.952] [INFO] [main] [ConsumerConfig values: 330 allow.auto.create.topics = true 331 auto.commit.interval.ms = 1000 332 auto.include.jmx.reporter = true 333 auto.offset.reset = latest 334 bootstrap.servers = [10.252.158.60:9092, 10.252.158.59:9092, 10.252.158.57:9092] 335 check.crcs = true 336 client.dns.lookup = use_all_dns_ips 337 client.id = consumer-oms_jdbc_connector_null-2 338 client.rack = 339 connections.max.idle.ms = 540000 340 default.api.timeout.ms = 60000 341 enable.auto.commit = true 342 exclude.internal.topics = true 343 fetch.max.bytes = 52428800 344 fetch.max.wait.ms = 500 345 fetch.min.bytes = 1 346 group.id = oms_jdbc_connector_null 347 group.instance.id = null 348 heartbeat.interval.ms = 60000 349 interceptor.classes = [] 350 internal.leave.group.on.close = true 351 internal.throw.on.fetch.stable.offset.unsupported = false 352 isolation.level = read_uncommitted 353 key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer 354 max.partition.fetch.bytes = 4388608 355 max.poll.interval.ms = 120000 356 max.poll.records = 1 357 metadata.max.age.ms = 300000 358 metric.reporters = [] 359 metrics.num.samples = 2 360 metrics.recording.level = INFO 361 metrics.sample.window.ms = 30000 362 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor] 363 receive.buffer.bytes = 65536 364 reconnect.backoff.max.ms = 1000 365 reconnect.backoff.ms = 50 366 request.timeout.ms = 300000 367 retry.backoff.ms = 100 368 sasl.client.callback.handler.class = null 369 sasl.jaas.config = null 370 sasl.kerberos.kinit.cmd = /usr/bin/kinit 371 sasl.kerberos.min.time.before.relogin = 60000 372 sasl.kerberos.service.name = null 373 sasl.kerberos.ticket.renew.jitter = 0.05 374 sasl.kerberos.ticket.renew.window.factor = 0.8 375 sasl.login.callback.handler.class = null 376 sasl.login.class = null 377 sasl.login.connect.timeout.ms = null 378 sasl.login.read.timeout.ms = null 379 sasl.login.refresh.buffer.seconds = 300 380 sasl.login.refresh.min.period.seconds = 60 381 sasl.login.refresh.window.factor = 0.8 382 sasl.login.refresh.window.jitter = 0.05 383 sasl.login.retry.backoff.max.ms = 10000 384 sasl.login.retry.backoff.ms = 100 385 sasl.mechanism = GSSAPI 386 sasl.oauthbearer.clock.skew.seconds = 30 387 sasl.oauthbearer.expected.audience = null 388 sasl.oauthbearer.expected.issuer = null 389 sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 390 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 391 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 392 sasl.oauthbearer.jwks.endpoint.url = null 393 sasl.oauthbearer.scope.claim.name = scope 394 sasl.oauthbearer.sub.claim.name = sub 395 sasl.oauthbearer.token.endpoint.url = null 396 security.protocol = PLAINTEXT 397 security.providers = null 398 send.buffer.bytes = 131072 399 session.timeout.ms = 80000 400 socket.connection.setup.timeout.max.ms = 30000 401 socket.connection.setup.timeout.ms = 10000 402 ssl.cipher.suites = null 403 ssl.enabled.protocols = [TLSv1.2] 404 ssl.endpoint.identification.algorithm = https 405 ssl.engine.factory.class = null 406 ssl.key.password = null 407 ssl.keymanager.algorithm = SunX509 408 ssl.keystore.certificate.chain = null 409 ssl.keystore.key = null 410 ssl.keystore.location = null 411 ssl.keystore.password = null 412 ssl.keystore.type = JKS 413 ssl.protocol = TLSv1.2 414 ssl.provider = null 415 ssl.secure.random.implementation = null 416 ssl.trustmanager.algorithm = PKIX 417 ssl.truststore.certificates = null 418 ssl.truststore.location = null 419 ssl.truststore.password = null 420 ssl.truststore.type = JKS 421 value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer 422 ] 423 [2025-08-25 17:11:04.965] [INFO] [main] [Kafka version: 3.4.0] 424 [2025-08-25 17:11:04.965] [INFO] [main] [Kafka commitId: 2e1947d240607d53] 425 [2025-08-25 17:11:04.965] [INFO] [main] [Kafka startTimeMs: 1756113064965] 426 [2025-08-25 17:11:04.977] [INFO] [main] [[Consumer clientId=consumer-oms_jdbc_connector_null-2, groupId=oms_jdbc_connector_null] Resetting the last seen epoch of partition oms-2 to 0 since the associated topicId changed from null to uG8kFjIGS5SJTihcGKzL_g] 427 [2025-08-25 17:11:04.978] [INFO] [main] [[Consumer clientId=consumer-oms_jdbc_connector_null-2, groupId=oms_jdbc_connector_null] Resetting the last seen epoch of partition oms-1 to 0 since the associated topicId changed from null to uG8kFjIGS5SJTihcGKzL_g] 428 [2025-08-25 17:11:04.978] [INFO] [main] [[Consumer clientId=consumer-oms_jdbc_connector_null-2, groupId=oms_jdbc_connector_null] Resetting the last seen epoch of partition oms-0 to 0 since the associated topicId changed from null to uG8kFjIGS5SJTihcGKzL_g] 429 [2025-08-25 17:11:04.978] [INFO] [main] [[Consumer clientId=consumer-oms_jdbc_connector_null-2, groupId=oms_jdbc_connector_null] Cluster ID: SqQYmotJTjOK9QK5duAA9g] 430 [2025-08-25 17:11:04.989] [INFO] [main] [[Consumer clientId=consumer-oms_jdbc_connector_null-2, groupId=oms_jdbc_connector_null] Assigned to partition(s): oms-2] 431 [2025-08-25 17:11:04.991] [INFO] [main] [[Consumer clientId=consumer-oms_jdbc_connector_null-2, groupId=oms_jdbc_connector_null] Seeking to offset 0 for partition oms-2] 432 [2025-08-25 17:11:05.059] [ERROR] [main] [notifyStopped:] 433 java.lang.RuntimeException: java.lang.RuntimeException: Illegal format, can not read version 434 at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:93) 435 at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:31) 436 at com.oceanbase.connector.framework.threadmanager.TaskManager.start(TaskManager.java:49) 437 at com.oceanbase.oms.connector.coordinator.BootStrapPanel.boot(BootStrapPanel.java:240) 438 at com.oceanbase.oms.connector.jdbc.coordinator.Bootstrap.main(Bootstrap.java:44) 439 Caused by: java.lang.RuntimeException: Illegal format, can not read version 440 at com.pingcap.ticdc.cdc.TicdcEventDecoder.readKeyVersion(TicdcEventDecoder.java:117) 441 at com.pingcap.ticdc.cdc.TicdcEventDecoder.(TicdcEventDecoder.java:85) 442 at com.oceanbase.oms.connector.source.kafka.tidb.TiDBCdcOpenProtocolResolver.resolveCheckpoint(TiDBCdcOpenProtocolResolver.java:95) 443 at com.oceanbase.oms.connector.source.kafka.KafkaClient.getOffset(KafkaClient.java:181) 444 at com.oceanbase.oms.connector.source.kafka.KafkaClient.getAllOffset(KafkaClient.java:145) 445 at com.oceanbase.oms.connector.source.kafka.KafkaClient.init(KafkaClient.java:57) 446 at com.oceanbase.oms.connector.source.kafka.KafkaSource.initialize(KafkaSource.java:69) 447 at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:85) 448 ... 4 common frames omitted 449 Caused by: java.io.EOFException: null 450 at java.io.DataInputStream.readFully(DataInputStream.java:197) 451 at java.io.DataInputStream.readLong(DataInputStream.java:416) 452 at com.pingcap.ticdc.cdc.TicdcEventDecoder.readKeyVersion(TicdcEventDecoder.java:115) 453 ... 11 common frames omitted 454 [2025-08-25 17:11:05.062] [INFO] [main] [close sourceTaskManager done] 455 [2025-08-25 17:11:05.062] [INFO] [main] [close sourceBooster done] 456 [2025-08-25 17:11:05.066] [INFO] [forward_slot0-(ETLProcessor)-queue_slot1] [SerialBridgeTask [forward_slot0-(ETLProcessor)-queue_slot1] stopped] 457 [2025-08-25 17:11:05.071] [INFO] [queue_slot1-()-TransactionScheduler] [SerialBridgeTask [queue_slot1-()-TransactionScheduler] stopped] 458 [2025-08-25 17:11:05.072] [INFO] [main] [close bridgeTaskManager done] 459 [2025-08-25 17:11:05.074] [INFO] [sinkTask-0] [SyncSinkTask [sinkTask-0] stopped] 460 [2025-08-25 17:11:05.074] [INFO] [sinkTask-0] [{dataSource-1} closing ...] 461 [2025-08-25 17:11:05.077] [INFO] [sinkTask-0] [{dataSource-1} closed] 462 [2025-08-25 17:11:05.077] [INFO] [sinkTask-0] [{dataSource-0} closing ...] 463 [2025-08-25 17:11:05.077] [INFO] [main] [{dataSource-0} closing ...] 464 [2025-08-25 17:11:05.079] [INFO] [sinkTask-1] [SyncSinkTask [sinkTask-1] stopped] 465 [2025-08-25 17:11:05.080] [INFO] [sinkTask-1] [{dataSource-0} closing ...] 466 [2025-08-25 17:11:05.080] [INFO] [main] [{dataSource-0} closing ...] 467 [2025-08-25 17:11:05.080] [INFO] [sinkTask-2] [SyncSinkTask [sinkTask-2] stopped] 468 [2025-08-25 17:11:05.080] [INFO] [sinkTask-2] [{dataSource-0} closing ...] 469 [2025-08-25 17:11:05.080] [INFO] [main] [{dataSource-0} closing ...] 470 [2025-08-25 17:11:05.085] [INFO] [sinkTask-3] [SyncSinkTask [sinkTask-3] stopped] 471 [2025-08-25 17:11:05.085] [INFO] [sinkTask-3] [{dataSource-0} closing ...] 472 [2025-08-25 17:11:05.085] [INFO] [main] [{dataSource-0} closing ...] 473 [2025-08-25 17:11:05.085] [INFO] [main] [close sinkTaskManager done] 474 [2025-08-25 17:11:05.085] [INFO] [main] [close sinkBooster done] 475 [2025-08-25 17:11:05.085] [INFO] [main] [close frameworkCustomize done] 476 [2025-08-25 17:11:05.085] [INFO] [main] [close reporter done] 477 [2025-08-25 17:11:05.085] [INFO] [main] [close httpServer done] 478 [2025-08-25 17:11:05.085] [INFO] [main] [close timerTaskScheduler done] 479 [2025-08-25 17:11:05.086] [WARN] [main] [FrameWork exist {}] 480 java.lang.RuntimeException: java.lang.RuntimeException: Illegal format, can not read version 481 at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:93) 482 at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:31) 483 at com.oceanbase.connector.framework.threadmanager.TaskManager.start(TaskManager.java:49) 484 at com.oceanbase.oms.connector.coordinator.BootStrapPanel.boot(BootStrapPanel.java:240) 485 at com.oceanbase.oms.connector.jdbc.coordinator.Bootstrap.main(Bootstrap.java:44) 486 Caused by: java.lang.RuntimeException: Illegal format, can not read version 487 at com.pingcap.ticdc.cdc.TicdcEventDecoder.readKeyVersion(TicdcEventDecoder.java:117) 488 at com.pingcap.ticdc.cdc.TicdcEventDecoder.(TicdcEventDecoder.java:85) 489 at com.oceanbase.oms.connector.source.kafka.tidb.TiDBCdcOpenProtocolResolver.resolveCheckpoint(TiDBCdcOpenProtocolResolver.java:95) 490 at com.oceanbase.oms.connector.source.kafka.KafkaClient.getOffset(KafkaClient.java:181) 491 at com.oceanbase.oms.connector.source.kafka.KafkaClient.getAllOffset(KafkaClient.java:145) 492 at com.oceanbase.oms.connector.source.kafka.KafkaClient.init(KafkaClient.java:57) 493 at com.oceanbase.oms.connector.source.kafka.KafkaSource.initialize(KafkaSource.java:69) 494 at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:85) 495 ... 4 common frames omitted 496 Caused by: java.io.EOFException: null 497 at java.io.DataInputStream.readFully(DataInputStream.java:197) 498 at java.io.DataInputStream.readLong(DataInputStream.java:416) 499 at com.pingcap.ticdc.cdc.TicdcEventDecoder.readKeyVersion(TicdcEventDecoder.java:115) 500 ... 11 common frames omitted 501 [2025-08-25 17:11:05.090] [ERROR] [main] [main thread error] 502 java.lang.RuntimeException: java.lang.RuntimeException: Illegal format, can not read version 503 at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:93) 504 at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:31) 505 at com.oceanbase.connector.framework.threadmanager.TaskManager.start(TaskManager.java:49) 506 at com.oceanbase.oms.connector.coordinator.BootStrapPanel.boot(BootStrapPanel.java:240) 507 at com.oceanbase.oms.connector.jdbc.coordinator.Bootstrap.main(Bootstrap.java:44) 508 Caused by: java.lang.RuntimeException: Illegal format, can not read version 509 at com.pingcap.ticdc.cdc.TicdcEventDecoder.readKeyVersion(TicdcEventDecoder.java:117) 510 at com.pingcap.ticdc.cdc.TicdcEventDecoder.(TicdcEventDecoder.java:85) 511 at com.oceanbase.oms.connector.source.kafka.tidb.TiDBCdcOpenProtocolResolver.resolveCheckpoint(TiDBCdcOpenProtocolResolver.java:95) 512 at com.oceanbase.oms.connector.source.kafka.KafkaClient.getOffset(KafkaClient.java:181) 513 at com.oceanbase.oms.connector.source.kafka.KafkaClient.getAllOffset(KafkaClient.java:145) 514 at com.oceanbase.oms.connector.source.kafka.KafkaClient.init(KafkaClient.java:57) 515 at com.oceanbase.oms.connector.source.kafka.KafkaSource.initialize(KafkaSource.java:69) 516 at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:85) 517 ... 4 common frames omitted 518 Caused by: java.io.EOFException: null 519 at java.io.DataInputStream.readFully(DataInputStream.java:197) 520 at java.io.DataInputStream.readLong(DataInputStream.java:416) 521 at com.pingcap.ticdc.cdc.TicdcEventDecoder.readKeyVersion(TicdcEventDecoder.java:115) 522 ... 11 common frames omitted 523 [2025-08-25 17:21:03.960] [INFO] [main] [NativeFSLock: acquire with pid [3223629]] 524 [2025-08-25 17:21:03.963] [INFO] [main] [error file not exists] 525 [2025-08-25 17:21:03.979] [INFO] [main] [system default timezone : GMT+08:00] 526 [2025-08-25 17:21:04.128] [INFO] [main] [build condition cache, caseInsensitive: false, condition : { 527 "DefaultConnectorCondition" : { 528 "blackCondition" : "[{\"all\":false,\"sub\":[{\"func\":\"fn\",\"name\":\"ds_ele_benchmark_billaccount\"},{\"func\":\"fn\",\"name\":\"ds_ele_benchmark_billaccount_month\"},{\"func\":\"fn\",\"name\":\"drc_txn*\"},{\"func\":\"fn\",\"name\":\"DRC_TXN*\"},{\"func\":\"fn\",\"name\":\"delay_delete_*\"},{\"func\":\"fn\",\"name\":\"DELAY_DELETE_*\"}],\"func\":\"fn\",\"name\":\"ncms_xz\",\"map\":\"ncms_xz\"}]", 529 "whiteCondition" : "[{\"all\":false,\"sub\":[{\"func\":\"fn\",\"name\":\"*benchmark_billaccount\"},{\"func\":\"fn\",\"name\":\"*benchmark_billaccount_month\"},{\"func\":\"fn\",\"name\":\"*_export\"},{\"name\":\"ocr_elemeter\",\"map\":\"ocr_elemeter_tidb\"},{\"name\":\"tele_benchmark_billaccount\",\"map\":\"tele_benchmark_billaccount_tidb\"},{\"name\":\"tele_benchmark_billaccount_month\",\"map\":\"tele_benchmark_billaccount_month_tidb\"},{\"name\":\"tele_payment_details_export\",\"map\":\"tele_payment_details_export_tidb\"},{\"name\":\"ele_benchmark_billaccount_month\",\"map\":\"ele_benchmark_billaccount_month_tidb\"},{\"name\":\"ele_benchmark_billaccount\",\"map\":\"ele_benchmark_billaccount_tidb\"},{\"name\":\"tele_other_amount_finance_export\",\"map\":\"tele_other_amount_finance_export_tidb\"},{\"name\":\"ele_other_amount_finance_export\",\"map\":\"ele_other_amount_finance_export_tidb\"}],\"func\":\"fn\",\"name\":\"ncms_xz\",\"map\":\"ncms_xz\"}]" 530 } 531 }] 532 [2025-08-25 17:21:04.150] [INFO] [main] [map source class [com.oceanbase.oms.connector.source.kafka.KafkaSourceBooster] to [com.oceanbase.oms.connector.source.kafka.KafkaSourceBooster]] 533 [2025-08-25 17:21:04.151] [INFO] [main] [map sink class [com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSinkBooster] to [com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSinkBooster]] 534 [2025-08-25 17:21:04.161] [WARN] [main] [MySQL not determinate utf8mb4 support or not] 535 [2025-08-25 17:21:04.161] [WARN] [main] [MySQL not determinate utf8mb4 support or not] 536 [2025-08-25 17:21:04.190] [INFO] [main] [auto set coordinator config: {bridgeQueueSize=64, throttleMemoryBound=1073741824} by metrics MID] 537 [2025-08-25 17:21:04.209] [INFO] [main] [CastConfig: com.oceanbase.oms.connector.common.cast.CastConfig@6989da5e] 538 [2025-08-25 17:21:04.221] [INFO] [main] [[condition]] 539 [2025-08-25 17:21:04.225] [INFO] [main] [ blackCondition = [{"all":false,"sub":[{"func":"fn","name":"ds_ele_benchmark_billaccount"},{"func":"fn","name":"ds_ele_benchmark_billaccount_month"},{"func":"fn","name":"drc_txn*"},{"func":"fn","name":"DRC_TXN*"},{"func":"fn","name":"delay_delete_*"},{"func":"fn","name":"DELAY_DELETE_*"}],"func":"fn","name":"ncms_xz","map":"ncms_xz"}]] 540 [2025-08-25 17:21:04.226] [INFO] [main] [ whiteCondition = [{"all":false,"sub":[{"func":"fn","name":"*benchmark_billaccount"},{"func":"fn","name":"*benchmark_billaccount_month"},{"func":"fn","name":"*_export"},{"name":"ocr_elemeter","map":"ocr_elemeter_tidb"},{"name":"tele_benchmark_billaccount","map":"tele_benchmark_billaccount_tidb"},{"name":"tele_benchmark_billaccount_month","map":"tele_benchmark_billaccount_month_tidb"},{"name":"tele_payment_details_export","map":"tele_payment_details_export_tidb"},{"name":"ele_benchmark_billaccount_month","map":"ele_benchmark_billaccount_month_tidb"},{"name":"ele_benchmark_billaccount","map":"ele_benchmark_billaccount_tidb"},{"name":"tele_other_amount_finance_export","map":"tele_other_amount_finance_export_tidb"},{"name":"ele_other_amount_finance_export","map":"ele_other_amount_finance_export_tidb"}],"func":"fn","name":"ncms_xz","map":"ncms_xz"}]] 541 [2025-08-25 17:21:04.226] [INFO] [main] [[coordinator]] 542 [2025-08-25 17:21:04.226] [INFO] [main] [ taskIdentity = np_70tg6g6fuekg] 543 [2025-08-25 17:21:04.226] [INFO] [main] [ enableOmsConnectorV2Report = true] 544 [2025-08-25 17:21:04.226] [INFO] [main] [ isCaseSensitive = true] 545 [2025-08-25 17:21:04.226] [INFO] [main] [ dbTableCaseStrategy = follow-source] 546 [2025-08-25 17:21:04.226] [INFO] [main] [ streamMode = true] 547 [2025-08-25 17:21:04.226] [INFO] [main] [ timezone = +08:00] 548 [2025-08-25 17:21:04.226] [INFO] [main] [ enableActiveReportTask = false] 549 [2025-08-25 17:21:04.226] [INFO] [main] [ bridgeQueueSize = 64] 550 [2025-08-25 17:21:04.226] [INFO] [main] [ mysqlVersion = 7.1.0] 551 [2025-08-25 17:21:04.226] [INFO] [main] [ enableMetricReportTask = false] 552 [2025-08-25 17:21:04.226] [INFO] [main] [ sourceType = MYSQL] 553 [2025-08-25 17:21:04.226] [INFO] [main] [ columnCaseStrategy = follow-source] 554 [2025-08-25 17:21:04.226] [INFO] [main] [ mysqlExplicitDefaultsForTimestamp = ON] 555 [2025-08-25 17:21:04.226] [INFO] [main] [ throttleMemoryBound = 1073741824] 556 [2025-08-25 17:21:04.226] [INFO] [main] [ sinkType = OB_MYSQL] 557 [2025-08-25 17:21:04.226] [INFO] [main] [ listenPort = 16000] 558 [2025-08-25 17:21:04.226] [INFO] [main] [ allowRecordTypes = DELETE,INSERT,UPDATE] 559 [2025-08-25 17:21:04.226] [INFO] [main] [ ignoreCompensateDDL = false] 560 [2025-08-25 17:21:04.226] [INFO] [main] [ connectorJvmParam = -Xms4096m -Xmx4096m -Xmn2048m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=128m -XX:+UseConcMarkSweepGC -XX:+UseParNewGC -XX:+CMSParallelRemarkEnabled -XX:+UseCMSInitiatingOccupancyOnly -XX:CMSInitiatingOccupancyFraction=70 -XX:+CMSClassUnloadingEnabled] 561 [2025-08-25 17:21:04.226] [INFO] [main] [[sink]] 562 [2025-08-25 17:21:04.227] [INFO] [main] [ boosterClass = com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSinkBooster] 563 [2025-08-25 17:21:04.227] [INFO] [main] [ enableNoUniqueConstraintTableReplicate = false] 564 [2025-08-25 17:21:04.227] [INFO] [main] [ dbTableCaseStrategy = follow-source] 565 [2025-08-25 17:21:04.227] [INFO] [main] [ dbVersion = 4.3.2.1] 566 [2025-08-25 17:21:04.227] [INFO] [main] [ endpointId = e_70beg7377y9s] 567 [2025-08-25 17:21:04.227] [INFO] [main] [ timezone = +08:00] 568 [2025-08-25 17:21:04.227] [INFO] [main] [ filterHiddenPK = false] 569 [2025-08-25 17:21:04.227] [INFO] [main] [ isPreLoadAllTableSchema = false] 570 [2025-08-25 17:21:04.227] [INFO] [main] [ type = JDBC_SINK_OB_MYSQL] 571 [2025-08-25 17:21:04.227] [INFO] [main] [ insertMode = INSERT] 572 [2025-08-25 17:21:04.227] [INFO] [main] [ password = Cmiot.ncms@123] 573 [2025-08-25 17:21:04.227] [INFO] [main] [ charsetReplaceMap = {}] 574 [2025-08-25 17:21:04.227] [INFO] [main] [ sourceType = TIDB] 575 [2025-08-25 17:21:04.227] [INFO] [main] [ columnCaseStrategy = follow-source] 576 [2025-08-25 17:21:04.227] [INFO] [main] [ jdbcUrl = jdbc:mysql://10.252.210.192:2883?useUnicode=true&allowMultiQueries=true&socketTimeout=50000&characterEncoding=utf8&readOnlyPropagatesToServer=false] 577 [2025-08-25 17:21:04.227] [INFO] [main] [ sinkMaps = [["ncms_xz","ele_other_amount_finance_export_tidb"],["ncms_xz","tele_other_amount_finance_export_tidb"],["ncms_xz","ele_benchmark_billaccount_tidb"],["ncms_xz","tele_benchmark_billaccount_month_tidb"],["ncms_xz","tele_payment_details_export_tidb"],["ncms_xz","ele_benchmark_billaccount_month_tidb"],["ncms_xz","tele_benchmark_billaccount_tidb"],["ncms_xz","ocr_elemeter_tidb"]]] 578 [2025-08-25 17:21:04.227] [INFO] [main] [ ignoreRedunantColumnsReplicate = false] 579 [2025-08-25 17:21:04.227] [INFO] [main] [ conflictTargetSchema = true] 580 [2025-08-25 17:21:04.227] [INFO] [main] [ jar = jdbc-sink-ob-mysql.jar] 581 [2025-08-25 17:21:04.227] [INFO] [main] [ workerNum = 4] 582 [2025-08-25 17:21:04.227] [INFO] [main] [ sinkType = OB_MYSQL] 583 [2025-08-25 17:21:04.227] [INFO] [main] [ tenant = ncms_xz] 584 [2025-08-25 17:21:04.227] [INFO] [main] [ username = fcncms@ncms_xz#ob_pro] 585 [2025-08-25 17:21:04.227] [INFO] [main] [[source]] 586 [2025-08-25 17:21:04.227] [INFO] [main] [ checkpoint = {"oms":"1756111699"}] 587 [2025-08-25 17:21:04.227] [INFO] [main] [ boosterClass = com.oceanbase.oms.connector.source.kafka.KafkaSourceBooster] 588 [2025-08-25 17:21:04.227] [INFO] [main] [ taskIdentity = np_70tg6g6fuekg] 589 [2025-08-25 17:21:04.227] [INFO] [main] [ enableOmsConnectorV2Report = true] 590 [2025-08-25 17:21:04.227] [INFO] [main] [ kafkaAddr = 10.252.158.60] 591 [2025-08-25 17:21:04.227] [INFO] [main] [ enableNoUniqueConstraintTableReplicate = false] 592 [2025-08-25 17:21:04.228] [INFO] [main] [ kafkaTopic = oms] 593 [2025-08-25 17:21:04.228] [INFO] [main] [ timezone = +08:00] 594 [2025-08-25 17:21:04.228] [INFO] [main] [ taskSubId = 1] 595 [2025-08-25 17:21:04.228] [INFO] [main] [ dbType = TIDB] 596 [2025-08-25 17:21:04.228] [INFO] [main] [ type = KAFKA_SOURCE] 597 [2025-08-25 17:21:04.228] [INFO] [main] [ taskType = migrate] 598 [2025-08-25 17:21:04.228] [INFO] [main] [ securityProtocol = PLAINTEXT] 599 [2025-08-25 17:21:04.228] [INFO] [main] [ kafkaServer = 10.252.158.60:9092,10.252.158.59:9092,10.252.158.57:9092] 600 [2025-08-25 17:21:04.228] [INFO] [main] [ jar = connector-source-kafka.jar] 601 [2025-08-25 17:21:04.228] [INFO] [main] [ kafkaPort = 9092] 602 [2025-08-25 17:21:04.228] [INFO] [main] [ properties = {}] 603 [2025-08-25 17:21:04.532] [INFO] [main] [[Init DruidDataSource]sessionParameters: {}] 604 [2025-08-25 17:21:04.536] [INFO] [main] [10.252.210.192:2883 fcncms@ncms_xz#ob_pro init sql:set foreign_key_checks = off] 605 [2025-08-25 17:21:04.538] [INFO] [main] [init druid dataSource with loginTimeout[300], maxWaitMillis[12000], maxActive[4], initActive[4], minIdle[4]] 606 [2025-08-25 17:21:04.540] [INFO] [main] [connect with url [jdbc:mysql://10.252.210.192:2883?readOnlyPropagatesToServer=false&useUnicode=true&rewriteBatchedStatements=true&socketTimeout=50000&connectTimeout=30000&allowMultiQueries=true&characterEncoding=utf8&netTimeoutForStreamingResults=28800&useSSL=false]] 607 [2025-08-25 17:21:04.541] [INFO] [main] [[SET TIME_ZONE='+08:00', set foreign_key_checks = off, set sql_mode='NO_AUTO_VALUE_ON_ZERO', set session sql_select_limit=9223372036854775807] for instance 10.252.210.192:2883 user fcncms@ncms_xz#ob_pro characterSet ] 608 [2025-08-25 17:21:04.556] [INFO] [main] [[Init DruidDataSource]sessionParameters: {}] 609 [2025-08-25 17:21:04.556] [INFO] [main] [10.252.210.192:2883 fcncms@ncms_xz#ob_pro init sql:set foreign_key_checks = off] 610 [2025-08-25 17:21:04.556] [INFO] [main] [init druid dataSource with loginTimeout[300], maxWaitMillis[12000], maxActive[3], initActive[0], minIdle[0]] 611 [2025-08-25 17:21:04.556] [INFO] [main] [connect with url [jdbc:mysql://10.252.210.192:2883?readOnlyPropagatesToServer=false&useUnicode=true&rewriteBatchedStatements=true&socketTimeout=172800000&connectTimeout=30000&allowMultiQueries=true&characterEncoding=utf8&netTimeoutForStreamingResults=28800&useSSL=false]] 612 [2025-08-25 17:21:04.556] [INFO] [main] [[SET TIME_ZONE='+08:00', set foreign_key_checks = off, set sql_mode='NO_AUTO_VALUE_ON_ZERO', set session sql_select_limit=9223372036854775807] for instance 10.252.210.192:2883 user fcncms@ncms_xz#ob_pro characterSet ] 613 [2025-08-25 17:21:04.723] [INFO] [main] [{dataSource-1} inited] 614 [2025-08-25 17:21:04.903] [INFO] [main] [SHOW VARIABLES LIKE 'version_comment'] 615 [2025-08-25 17:21:04.907] [INFO] [main] [sink db version:4.3.2.1] 616 [2025-08-25 17:21:05.028] [INFO] [main] [Inited OBHighWatermarkMonitor. querySql. [OB_MYSQL], cpuSQL: select /*+query_timeout(5000000)*/ 100 - max(round(memstore_used/memstore_limit*100)) from oceanbase.GV$OB_MEMSTORE, memSQL: select /*+query_timeout(5000000)*/ 100 - max(round(memstore_used/memstore_limit*100)) from oceanbase.GV$OB_MEMSTORE] 617 [2025-08-25 17:21:05.038] [INFO] [main] [put coordinator.maxRecordCapacity: batchSize(128), workerNum(4), maxRecordCapacity: 16384, may have been set, so it's inconsistent with cal value ] 618 [2025-08-25 17:21:05.087] [WARN] [main] [MySQL not determinate utf8mb4 support or not] 619 [2025-08-25 17:21:05.100] [INFO] [main] [[Init DruidDataSource]sessionParameters: {}] 620 [2025-08-25 17:21:05.100] [INFO] [main] [10.252.210.192:2883 fcncms@ncms_xz#ob_pro init sql:set foreign_key_checks = off] 621 [2025-08-25 17:21:05.100] [INFO] [main] [init druid dataSource with loginTimeout[300], maxWaitMillis[12000], maxActive[3], initActive[0], minIdle[0]] 622 [2025-08-25 17:21:05.100] [INFO] [main] [connect with url [jdbc:mysql://10.252.210.192:2883?readOnlyPropagatesToServer=false&useUnicode=true&rewriteBatchedStatements=true&socketTimeout=1800000&connectTimeout=30000&allowMultiQueries=true&characterEncoding=utf8&netTimeoutForStreamingResults=28800&useSSL=false]] 623 [2025-08-25 17:21:05.100] [INFO] [main] [[SET TIME_ZONE='+00:00', set foreign_key_checks = off, set sql_mode='NO_AUTO_VALUE_ON_ZERO', set session sql_select_limit=9223372036854775807] for instance 10.252.210.192:2883 user fcncms@ncms_xz#ob_pro characterSet utf8] 624 [2025-08-25 17:21:05.100] [INFO] [main] [create jdbc:mysql://10.252.210.192:2883?useUnicode=true&allowMultiQueries=true&socketTimeout=50000&characterEncoding=utf8&readOnlyPropagatesToServer=false|fcncms@ncms_xz#ob_pro|UTF8|default data source success , charset : utf8 , sql timeout : 1800000 , {sql_select_limit=9223372036854775807, timezone=+08:00}] 625 [2025-08-25 17:21:05.100] [INFO] [main] [init datasource success : jdbc:mysql://10.252.210.192:2883?useUnicode=true&allowMultiQueries=true&socketTimeout=50000&characterEncoding=utf8&readOnlyPropagatesToServer=false] 626 [2025-08-25 17:21:05.124] [INFO] [main] [ConcurrentArrayQueue mod MULTI_PRODUCER_MULTI_CONSUMER, size: 64] 627 [2025-08-25 17:21:05.128] [INFO] [main] [ConcurrentArrayQueue mod MULTI_PRODUCER_MULTI_CONSUMER, size: 64] 628 [2025-08-25 17:21:05.139] [INFO] [main] [[condition]] 629 [2025-08-25 17:21:05.140] [INFO] [main] [ blackCondition = [{"all":false,"sub":[{"func":"fn","name":"ds_ele_benchmark_billaccount"},{"func":"fn","name":"ds_ele_benchmark_billaccount_month"},{"func":"fn","name":"drc_txn*"},{"func":"fn","name":"DRC_TXN*"},{"func":"fn","name":"delay_delete_*"},{"func":"fn","name":"DELAY_DELETE_*"}],"func":"fn","name":"ncms_xz","map":"ncms_xz"}]] 630 [2025-08-25 17:21:05.140] [INFO] [main] [ whiteCondition = [{"all":false,"sub":[{"func":"fn","name":"*benchmark_billaccount"},{"func":"fn","name":"*benchmark_billaccount_month"},{"func":"fn","name":"*_export"},{"name":"ocr_elemeter","map":"ocr_elemeter_tidb"},{"name":"tele_benchmark_billaccount","map":"tele_benchmark_billaccount_tidb"},{"name":"tele_benchmark_billaccount_month","map":"tele_benchmark_billaccount_month_tidb"},{"name":"tele_payment_details_export","map":"tele_payment_details_export_tidb"},{"name":"ele_benchmark_billaccount_month","map":"ele_benchmark_billaccount_month_tidb"},{"name":"ele_benchmark_billaccount","map":"ele_benchmark_billaccount_tidb"},{"name":"tele_other_amount_finance_export","map":"tele_other_amount_finance_export_tidb"},{"name":"ele_other_amount_finance_export","map":"ele_other_amount_finance_export_tidb"}],"func":"fn","name":"ncms_xz","map":"ncms_xz"}]] 631 [2025-08-25 17:21:05.140] [INFO] [main] [[coordinator]] 632 [2025-08-25 17:21:05.140] [INFO] [main] [ taskIdentity = np_70tg6g6fuekg] 633 [2025-08-25 17:21:05.140] [INFO] [main] [ enableOmsConnectorV2Report = true] 634 [2025-08-25 17:21:05.140] [INFO] [main] [ isCaseSensitive = true] 635 [2025-08-25 17:21:05.140] [INFO] [main] [ dbTableCaseStrategy = follow-source] 636 [2025-08-25 17:21:05.140] [INFO] [main] [ streamMode = true] 637 [2025-08-25 17:21:05.140] [INFO] [main] [ maxRecordCapacity = 16384] 638 [2025-08-25 17:21:05.140] [INFO] [main] [ timezone = +08:00] 639 [2025-08-25 17:21:05.140] [INFO] [main] [ enableActiveReportTask = false] 640 [2025-08-25 17:21:05.140] [INFO] [main] [ bridgeQueueSize = 64] 641 [2025-08-25 17:21:05.140] [INFO] [main] [ mysqlVersion = 7.1.0] 642 [2025-08-25 17:21:05.140] [INFO] [main] [ enableMetricReportTask = false] 643 [2025-08-25 17:21:05.140] [INFO] [main] [ sourceType = MYSQL] 644 [2025-08-25 17:21:05.140] [INFO] [main] [ columnCaseStrategy = follow-source] 645 [2025-08-25 17:21:05.140] [INFO] [main] [ mysqlExplicitDefaultsForTimestamp = ON] 646 [2025-08-25 17:21:05.140] [INFO] [main] [ throttleMemoryBound = 1073741824] 647 [2025-08-25 17:21:05.140] [INFO] [main] [ sinkType = OB_MYSQL] 648 [2025-08-25 17:21:05.140] [INFO] [main] [ dispatcherClassName = com.oceanbase.oms.connector.dispatcher.scheduler.DefaultTransactionScheduler] 649 [2025-08-25 17:21:05.140] [INFO] [main] [ listenPort = 16000] 650 [2025-08-25 17:21:05.140] [INFO] [main] [ allowRecordTypes = DELETE,INSERT,UPDATE] 651 [2025-08-25 17:21:05.140] [INFO] [main] [ ignoreCompensateDDL = false] 652 [2025-08-25 17:21:05.140] [INFO] [main] [ connectorJvmParam = -Xms4096m -Xmx4096m -Xmn2048m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=128m -XX:+UseConcMarkSweepGC -XX:+UseParNewGC -XX:+CMSParallelRemarkEnabled -XX:+UseCMSInitiatingOccupancyOnly -XX:CMSInitiatingOccupancyFraction=70 -XX:+CMSClassUnloadingEnabled] 653 [2025-08-25 17:21:05.140] [INFO] [main] [[sink]] 654 [2025-08-25 17:21:05.140] [INFO] [main] [ boosterClass = com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSinkBooster] 655 [2025-08-25 17:21:05.140] [INFO] [main] [ timezone = +08:00] 656 [2025-08-25 17:21:05.140] [INFO] [main] [ filterHiddenPK = false] 657 [2025-08-25 17:21:05.140] [INFO] [main] [ isPreLoadAllTableSchema = false] 658 [2025-08-25 17:21:05.140] [INFO] [main] [ type = JDBC_SINK_OB_MYSQL] 659 [2025-08-25 17:21:05.140] [INFO] [main] [ password = Cmiot.ncms@123] 660 [2025-08-25 17:21:05.141] [INFO] [main] [ columnCaseStrategy = follow-source] 661 [2025-08-25 17:21:05.141] [INFO] [main] [ sinkMaps = [["ncms_xz","ele_other_amount_finance_export_tidb"],["ncms_xz","tele_other_amount_finance_export_tidb"],["ncms_xz","ele_benchmark_billaccount_tidb"],["ncms_xz","tele_benchmark_billaccount_month_tidb"],["ncms_xz","tele_payment_details_export_tidb"],["ncms_xz","ele_benchmark_billaccount_month_tidb"],["ncms_xz","tele_benchmark_billaccount_tidb"],["ncms_xz","ocr_elemeter_tidb"]]] 662 [2025-08-25 17:21:05.141] [INFO] [main] [ conflictTargetSchema = true] 663 [2025-08-25 17:21:05.141] [INFO] [main] [ jar = jdbc-sink-ob-mysql.jar] 664 [2025-08-25 17:21:05.141] [INFO] [main] [ enableTransactionWriter = true] 665 [2025-08-25 17:21:05.141] [INFO] [main] [ supportedTimezone = []] 666 [2025-08-25 17:21:05.141] [INFO] [main] [ tenant = ncms_xz] 667 [2025-08-25 17:21:05.141] [INFO] [main] [ enableNoUniqueConstraintTableReplicate = false] 668 [2025-08-25 17:21:05.141] [INFO] [main] [ dbTableCaseStrategy = follow-source] 669 [2025-08-25 17:21:05.141] [INFO] [main] [ dbVersion = 4.3.2.1] 670 [2025-08-25 17:21:05.141] [INFO] [main] [ endpointId = e_70beg7377y9s] 671 [2025-08-25 17:21:05.141] [INFO] [main] [ insertMode = INSERT] 672 [2025-08-25 17:21:05.141] [INFO] [main] [ charsetReplaceMap = {}] 673 [2025-08-25 17:21:05.141] [INFO] [main] [ sourceType = TIDB] 674 [2025-08-25 17:21:05.141] [INFO] [main] [ jdbcUrl = jdbc:mysql://10.252.210.192:2883?useUnicode=true&allowMultiQueries=true&socketTimeout=50000&characterEncoding=utf8&readOnlyPropagatesToServer=false] 675 [2025-08-25 17:21:05.141] [INFO] [main] [ ignoreRedunantColumnsReplicate = false] 676 [2025-08-25 17:21:05.141] [INFO] [main] [ workerNum = 4] 677 [2025-08-25 17:21:05.141] [INFO] [main] [ sinkType = OB_MYSQL] 678 [2025-08-25 17:21:05.141] [INFO] [main] [ username = fcncms@ncms_xz#ob_pro] 679 [2025-08-25 17:21:05.141] [INFO] [main] [[source]] 680 [2025-08-25 17:21:05.141] [INFO] [main] [ checkpoint = {"oms":"1756111699"}] 681 [2025-08-25 17:21:05.141] [INFO] [main] [ boosterClass = com.oceanbase.oms.connector.source.kafka.KafkaSourceBooster] 682 [2025-08-25 17:21:05.141] [INFO] [main] [ taskIdentity = np_70tg6g6fuekg] 683 [2025-08-25 17:21:05.141] [INFO] [main] [ enableOmsConnectorV2Report = true] 684 [2025-08-25 17:21:05.141] [INFO] [main] [ kafkaAddr = 10.252.158.60] 685 [2025-08-25 17:21:05.141] [INFO] [main] [ enableNoUniqueConstraintTableReplicate = false] 686 [2025-08-25 17:21:05.141] [INFO] [main] [ kafkaTopic = oms] 687 [2025-08-25 17:21:05.141] [INFO] [main] [ timezone = +08:00] 688 [2025-08-25 17:21:05.141] [INFO] [main] [ taskSubId = 1] 689 [2025-08-25 17:21:05.141] [INFO] [main] [ dbType = TIDB] 690 [2025-08-25 17:21:05.141] [INFO] [main] [ type = KAFKA_SOURCE] 691 [2025-08-25 17:21:05.141] [INFO] [main] [ taskType = migrate] 692 [2025-08-25 17:21:05.141] [INFO] [main] [ securityProtocol = PLAINTEXT] 693 [2025-08-25 17:21:05.141] [INFO] [main] [ kafkaServer = 10.252.158.60:9092,10.252.158.59:9092,10.252.158.57:9092] 694 [2025-08-25 17:21:05.141] [INFO] [main] [ jar = connector-source-kafka.jar] 695 [2025-08-25 17:21:05.141] [INFO] [main] [ kafkaPort = 9092] 696 [2025-08-25 17:21:05.141] [INFO] [main] [ properties = {}] 697 [2025-08-25 17:21:05.148] [INFO] [main] [BootStrap: init memoryBoound value to 1073741824] 698 [2025-08-25 17:21:05.152] [INFO] [main] [BootStrapPanel: register keep alive url [/status]] 699 [2025-08-25 17:21:05.153] [INFO] [main] [BootStrapPanel: register source stats url [/source/stats]] 700 [2025-08-25 17:21:05.154] [INFO] [main] [BootStrapPanel: register checkpoint query url [/checkpoint/query]] 701 [2025-08-25 17:21:05.154] [INFO] [main] [BootStrapPanel: register throttle control url [/throttle/control]] 702 [2025-08-25 17:21:05.155] [INFO] [main] [BootStrapPanel: register throttle query url [/throttle/query]] 703 [2025-08-25 17:21:05.173] [INFO] [main] [Writer init with arguments, write mode[SEMI_BATCH_PREPARE_STATEMENT], maxTxnRetryTimes[1000], retryIntervalTime[1000],dryRun[false], printSql[false], slowSqlThreshold[15], ignoreDDL[true], hotKeyMerge[false]typeStatistics[false], fullBatchWithSameTable[false], canLobBatched[true]] 704 [2025-08-25 17:21:05.174] [INFO] [main] [Writer init with arguments, write mode[SEMI_BATCH_PREPARE_STATEMENT], maxTxnRetryTimes[1000], retryIntervalTime[1000],dryRun[false], printSql[false], slowSqlThreshold[15], ignoreDDL[true], hotKeyMerge[false]typeStatistics[false], fullBatchWithSameTable[false], canLobBatched[true]] 705 [2025-08-25 17:21:05.174] [INFO] [main] [Writer init with arguments, write mode[SEMI_BATCH_PREPARE_STATEMENT], maxTxnRetryTimes[1000], retryIntervalTime[1000],dryRun[false], printSql[false], slowSqlThreshold[15], ignoreDDL[true], hotKeyMerge[false]typeStatistics[false], fullBatchWithSameTable[false], canLobBatched[true]] 706 [2025-08-25 17:21:05.175] [INFO] [main] [Writer init with arguments, write mode[SEMI_BATCH_PREPARE_STATEMENT], maxTxnRetryTimes[1000], retryIntervalTime[1000],dryRun[false], printSql[false], slowSqlThreshold[15], ignoreDDL[true], hotKeyMerge[false]typeStatistics[false], fullBatchWithSameTable[false], canLobBatched[true]] 707 [2025-08-25 17:21:05.183] [INFO] [main] [KafkaConsumer properties: {security.protocol=PLAINTEXT, enable.auto.commit=true, max.poll.records=100, value.deserializer=org.apache.kafka.common.serialization.ByteArrayDeserializer, group.id=oms_jdbc_connector_null, request.timeout.ms=300000, session.timeout.ms=80000, bootstrap.servers=10.252.158.60:9092,10.252.158.59:9092,10.252.158.57:9092, max.partition.fetch.bytes=4388608, max.poll.interval.ms=120000, heartbeat.interval.ms=60000, key.deserializer=org.apache.kafka.common.serialization.ByteArrayDeserializer, auto.commit.interval.ms=1000}] 708 [2025-08-25 17:21:05.211] [INFO] [main] [ConsumerConfig values: 709 allow.auto.create.topics = true 710 auto.commit.interval.ms = 1000 711 auto.include.jmx.reporter = true 712 auto.offset.reset = latest 713 bootstrap.servers = [10.252.158.60:9092, 10.252.158.59:9092, 10.252.158.57:9092] 714 check.crcs = true 715 client.dns.lookup = use_all_dns_ips 716 client.id = consumer-oms_jdbc_connector_null-1 717 client.rack = 718 connections.max.idle.ms = 540000 719 default.api.timeout.ms = 60000 720 enable.auto.commit = true 721 exclude.internal.topics = true 722 fetch.max.bytes = 52428800 723 fetch.max.wait.ms = 500 724 fetch.min.bytes = 1 725 group.id = oms_jdbc_connector_null 726 group.instance.id = null 727 heartbeat.interval.ms = 60000 728 interceptor.classes = [] 729 internal.leave.group.on.close = true 730 internal.throw.on.fetch.stable.offset.unsupported = false 731 isolation.level = read_uncommitted 732 key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer 733 max.partition.fetch.bytes = 4388608 734 max.poll.interval.ms = 120000 735 max.poll.records = 100 736 metadata.max.age.ms = 300000 737 metric.reporters = [] 738 metrics.num.samples = 2 739 metrics.recording.level = INFO 740 metrics.sample.window.ms = 30000 741 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor] 742 receive.buffer.bytes = 65536 743 reconnect.backoff.max.ms = 1000 744 reconnect.backoff.ms = 50 745 request.timeout.ms = 300000 746 retry.backoff.ms = 100 747 sasl.client.callback.handler.class = null 748 sasl.jaas.config = null 749 sasl.kerberos.kinit.cmd = /usr/bin/kinit 750 sasl.kerberos.min.time.before.relogin = 60000 751 sasl.kerberos.service.name = null 752 sasl.kerberos.ticket.renew.jitter = 0.05 753 sasl.kerberos.ticket.renew.window.factor = 0.8 754 sasl.login.callback.handler.class = null 755 sasl.login.class = null 756 sasl.login.connect.timeout.ms = null 757 sasl.login.read.timeout.ms = null 758 sasl.login.refresh.buffer.seconds = 300 759 sasl.login.refresh.min.period.seconds = 60 760 sasl.login.refresh.window.factor = 0.8 761 sasl.login.refresh.window.jitter = 0.05 762 sasl.login.retry.backoff.max.ms = 10000 763 sasl.login.retry.backoff.ms = 100 764 sasl.mechanism = GSSAPI 765 sasl.oauthbearer.clock.skew.seconds = 30 766 sasl.oauthbearer.expected.audience = null 767 sasl.oauthbearer.expected.issuer = null 768 sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 769 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 770 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 771 sasl.oauthbearer.jwks.endpoint.url = null 772 sasl.oauthbearer.scope.claim.name = scope 773 sasl.oauthbearer.sub.claim.name = sub 774 sasl.oauthbearer.token.endpoint.url = null 775 security.protocol = PLAINTEXT 776 security.providers = null 777 send.buffer.bytes = 131072 778 session.timeout.ms = 80000 779 socket.connection.setup.timeout.max.ms = 30000 780 socket.connection.setup.timeout.ms = 10000 781 ssl.cipher.suites = null 782 ssl.enabled.protocols = [TLSv1.2] 783 ssl.endpoint.identification.algorithm = https 784 ssl.engine.factory.class = null 785 ssl.key.password = null 786 ssl.keymanager.algorithm = SunX509 787 ssl.keystore.certificate.chain = null 788 ssl.keystore.key = null 789 ssl.keystore.location = null 790 ssl.keystore.password = null 791 ssl.keystore.type = JKS 792 ssl.protocol = TLSv1.2 793 ssl.provider = null 794 ssl.secure.random.implementation = null 795 ssl.trustmanager.algorithm = PKIX 796 ssl.truststore.certificates = null 797 ssl.truststore.location = null 798 ssl.truststore.password = null 799 ssl.truststore.type = JKS 800 value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer 801 ] 802 [2025-08-25 17:21:05.290] [INFO] [main] [Kafka version: 3.4.0] 803 [2025-08-25 17:21:05.290] [INFO] [main] [Kafka commitId: 2e1947d240607d53] 804 [2025-08-25 17:21:05.290] [INFO] [main] [Kafka startTimeMs: 1756113665289] 805 [2025-08-25 17:21:05.599] [INFO] [main] [[Consumer clientId=consumer-oms_jdbc_connector_null-1, groupId=oms_jdbc_connector_null] Cluster ID: SqQYmotJTjOK9QK5duAA9g] 806 [2025-08-25 17:21:05.603] [INFO] [main] [KafkaConsumer properties: {security.protocol=PLAINTEXT, enable.auto.commit=true, max.poll.records=100, value.deserializer=org.apache.kafka.common.serialization.ByteArrayDeserializer, group.id=oms_jdbc_connector_null, request.timeout.ms=300000, session.timeout.ms=80000, bootstrap.servers=10.252.158.60:9092,10.252.158.59:9092,10.252.158.57:9092, max.partition.fetch.bytes=4388608, max.poll.interval.ms=120000, heartbeat.interval.ms=60000, key.deserializer=org.apache.kafka.common.serialization.ByteArrayDeserializer, auto.commit.interval.ms=1000}] 807 [2025-08-25 17:21:05.603] [INFO] [main] [ConsumerConfig values: 808 allow.auto.create.topics = true 809 auto.commit.interval.ms = 1000 810 auto.include.jmx.reporter = true 811 auto.offset.reset = latest 812 bootstrap.servers = [10.252.158.60:9092, 10.252.158.59:9092, 10.252.158.57:9092] 813 check.crcs = true 814 client.dns.lookup = use_all_dns_ips 815 client.id = consumer-oms_jdbc_connector_null-2 816 client.rack = 817 connections.max.idle.ms = 540000 818 default.api.timeout.ms = 60000 819 enable.auto.commit = true 820 exclude.internal.topics = true 821 fetch.max.bytes = 52428800 822 fetch.max.wait.ms = 500 823 fetch.min.bytes = 1 824 group.id = oms_jdbc_connector_null 825 group.instance.id = null 826 heartbeat.interval.ms = 60000 827 interceptor.classes = [] 828 internal.leave.group.on.close = true 829 internal.throw.on.fetch.stable.offset.unsupported = false 830 isolation.level = read_uncommitted 831 key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer 832 max.partition.fetch.bytes = 4388608 833 max.poll.interval.ms = 120000 834 max.poll.records = 1 835 metadata.max.age.ms = 300000 836 metric.reporters = [] 837 metrics.num.samples = 2 838 metrics.recording.level = INFO 839 metrics.sample.window.ms = 30000 840 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor] 841 receive.buffer.bytes = 65536 842 reconnect.backoff.max.ms = 1000 843 reconnect.backoff.ms = 50 844 request.timeout.ms = 300000 845 retry.backoff.ms = 100 846 sasl.client.callback.handler.class = null 847 sasl.jaas.config = null 848 sasl.kerberos.kinit.cmd = /usr/bin/kinit 849 sasl.kerberos.min.time.before.relogin = 60000 850 sasl.kerberos.service.name = null 851 sasl.kerberos.ticket.renew.jitter = 0.05 852 sasl.kerberos.ticket.renew.window.factor = 0.8 853 sasl.login.callback.handler.class = null 854 sasl.login.class = null 855 sasl.login.connect.timeout.ms = null 856 sasl.login.read.timeout.ms = null 857 sasl.login.refresh.buffer.seconds = 300 858 sasl.login.refresh.min.period.seconds = 60 859 sasl.login.refresh.window.factor = 0.8 860 sasl.login.refresh.window.jitter = 0.05 861 sasl.login.retry.backoff.max.ms = 10000 862 sasl.login.retry.backoff.ms = 100 863 sasl.mechanism = GSSAPI 864 sasl.oauthbearer.clock.skew.seconds = 30 865 sasl.oauthbearer.expected.audience = null 866 sasl.oauthbearer.expected.issuer = null 867 sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 868 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 869 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 870 sasl.oauthbearer.jwks.endpoint.url = null 871 sasl.oauthbearer.scope.claim.name = scope 872 sasl.oauthbearer.sub.claim.name = sub 873 sasl.oauthbearer.token.endpoint.url = null 874 security.protocol = PLAINTEXT 875 security.providers = null 876 send.buffer.bytes = 131072 877 session.timeout.ms = 80000 878 socket.connection.setup.timeout.max.ms = 30000 879 socket.connection.setup.timeout.ms = 10000 880 ssl.cipher.suites = null 881 ssl.enabled.protocols = [TLSv1.2] 882 ssl.endpoint.identification.algorithm = https 883 ssl.engine.factory.class = null 884 ssl.key.password = null 885 ssl.keymanager.algorithm = SunX509 886 ssl.keystore.certificate.chain = null 887 ssl.keystore.key = null 888 ssl.keystore.location = null 889 ssl.keystore.password = null 890 ssl.keystore.type = JKS 891 ssl.protocol = TLSv1.2 892 ssl.provider = null 893 ssl.secure.random.implementation = null 894 ssl.trustmanager.algorithm = PKIX 895 ssl.truststore.certificates = null 896 ssl.truststore.location = null 897 ssl.truststore.password = null 898 ssl.truststore.type = JKS 899 value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer 900 ] 901 [2025-08-25 17:21:05.617] [INFO] [main] [Kafka version: 3.4.0] 902 [2025-08-25 17:21:05.617] [INFO] [main] [Kafka commitId: 2e1947d240607d53] 903 [2025-08-25 17:21:05.617] [INFO] [main] [Kafka startTimeMs: 1756113665617] 904 [2025-08-25 17:21:05.629] [INFO] [main] [[Consumer clientId=consumer-oms_jdbc_connector_null-2, groupId=oms_jdbc_connector_null] Resetting the last seen epoch of partition oms-2 to 0 since the associated topicId changed from null to uG8kFjIGS5SJTihcGKzL_g] 905 [2025-08-25 17:21:05.630] [INFO] [main] [[Consumer clientId=consumer-oms_jdbc_connector_null-2, groupId=oms_jdbc_connector_null] Resetting the last seen epoch of partition oms-1 to 0 since the associated topicId changed from null to uG8kFjIGS5SJTihcGKzL_g] 906 [2025-08-25 17:21:05.630] [INFO] [main] [[Consumer clientId=consumer-oms_jdbc_connector_null-2, groupId=oms_jdbc_connector_null] Resetting the last seen epoch of partition oms-0 to 0 since the associated topicId changed from null to uG8kFjIGS5SJTihcGKzL_g] 907 [2025-08-25 17:21:05.630] [INFO] [main] [[Consumer clientId=consumer-oms_jdbc_connector_null-2, groupId=oms_jdbc_connector_null] Cluster ID: SqQYmotJTjOK9QK5duAA9g] 908 [2025-08-25 17:21:05.639] [INFO] [main] [[Consumer clientId=consumer-oms_jdbc_connector_null-2, groupId=oms_jdbc_connector_null] Assigned to partition(s): oms-2] 909 [2025-08-25 17:21:05.641] [INFO] [main] [[Consumer clientId=consumer-oms_jdbc_connector_null-2, groupId=oms_jdbc_connector_null] Seeking to offset 0 for partition oms-2] 910 [2025-08-25 17:21:05.712] [ERROR] [main] [notifyStopped:] 911 java.lang.RuntimeException: java.lang.RuntimeException: Illegal format, can not read version 912 at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:93) 913 at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:31) 914 at com.oceanbase.connector.framework.threadmanager.TaskManager.start(TaskManager.java:49) 915 at com.oceanbase.oms.connector.coordinator.BootStrapPanel.boot(BootStrapPanel.java:240) 916 at com.oceanbase.oms.connector.jdbc.coordinator.Bootstrap.main(Bootstrap.java:44) 917 Caused by: java.lang.RuntimeException: Illegal format, can not read version 918 at com.pingcap.ticdc.cdc.TicdcEventDecoder.readKeyVersion(TicdcEventDecoder.java:117) 919 at com.pingcap.ticdc.cdc.TicdcEventDecoder.(TicdcEventDecoder.java:85) 920 at com.oceanbase.oms.connector.source.kafka.tidb.TiDBCdcOpenProtocolResolver.resolveCheckpoint(TiDBCdcOpenProtocolResolver.java:95) 921 at com.oceanbase.oms.connector.source.kafka.KafkaClient.getOffset(KafkaClient.java:181) 922 at com.oceanbase.oms.connector.source.kafka.KafkaClient.getAllOffset(KafkaClient.java:145) 923 at com.oceanbase.oms.connector.source.kafka.KafkaClient.init(KafkaClient.java:57) 924 at com.oceanbase.oms.connector.source.kafka.KafkaSource.initialize(KafkaSource.java:69) 925 at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:85) 926 ... 4 common frames omitted 927 Caused by: java.io.EOFException: null 928 at java.io.DataInputStream.readFully(DataInputStream.java:197) 929 at java.io.DataInputStream.readLong(DataInputStream.java:416) 930 at com.pingcap.ticdc.cdc.TicdcEventDecoder.readKeyVersion(TicdcEventDecoder.java:115) 931 ... 11 common frames omitted 932 [2025-08-25 17:21:05.716] [INFO] [main] [close sourceTaskManager done] 933 [2025-08-25 17:21:05.716] [INFO] [main] [close sourceBooster done] 934 [2025-08-25 17:21:05.721] [INFO] [forward_slot0-(ETLProcessor)-queue_slot1] [SerialBridgeTask [forward_slot0-(ETLProcessor)-queue_slot1] stopped] 935 [2025-08-25 17:21:05.726] [INFO] [queue_slot1-()-TransactionScheduler] [SerialBridgeTask [queue_slot1-()-TransactionScheduler] stopped] 936 [2025-08-25 17:21:05.726] [INFO] [main] [close bridgeTaskManager done] 937 [2025-08-25 17:21:05.731] [INFO] [sinkTask-0] [SyncSinkTask [sinkTask-0] stopped] 938 [2025-08-25 17:21:05.731] [INFO] [sinkTask-0] [{dataSource-1} closing ...] 939 [2025-08-25 17:21:05.733] [INFO] [sinkTask-0] [{dataSource-1} closed] 940 [2025-08-25 17:21:05.734] [INFO] [sinkTask-0] [{dataSource-0} closing ...] 941 [2025-08-25 17:21:05.734] [INFO] [main] [{dataSource-0} closing ...] 942 [2025-08-25 17:21:05.737] [INFO] [sinkTask-1] [SyncSinkTask [sinkTask-1] stopped] 943 [2025-08-25 17:21:05.737] [INFO] [sinkTask-1] [{dataSource-0} closing ...] 944 [2025-08-25 17:21:05.737] [INFO] [main] [{dataSource-0} closing ...] 945 [2025-08-25 17:21:05.741] [INFO] [sinkTask-2] [SyncSinkTask [sinkTask-2] stopped] 946 [2025-08-25 17:21:05.741] [INFO] [sinkTask-2] [{dataSource-0} closing ...] 947 [2025-08-25 17:21:05.741] [INFO] [main] [{dataSource-0} closing ...] 948 [2025-08-25 17:21:05.746] [INFO] [sinkTask-3] [SyncSinkTask [sinkTask-3] stopped] 949 [2025-08-25 17:21:05.746] [INFO] [sinkTask-3] [{dataSource-0} closing ...] 950 [2025-08-25 17:21:05.746] [INFO] [main] [{dataSource-0} closing ...] 951 [2025-08-25 17:21:05.746] [INFO] [main] [close sinkTaskManager done] 952 [2025-08-25 17:21:05.747] [INFO] [main] [close sinkBooster done] 953 [2025-08-25 17:21:05.747] [INFO] [main] [close frameworkCustomize done] 954 [2025-08-25 17:21:05.747] [INFO] [main] [close reporter done] 955 [2025-08-25 17:21:05.747] [INFO] [main] [close httpServer done] 956 [2025-08-25 17:21:05.747] [INFO] [main] [close timerTaskScheduler done] 957 [2025-08-25 17:21:05.747] [WARN] [main] [FrameWork exist {}] 958 java.lang.RuntimeException: java.lang.RuntimeException: Illegal format, can not read version 959 at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:93) 960 at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:31) 961 at com.oceanbase.connector.framework.threadmanager.TaskManager.start(TaskManager.java:49) 962 at com.oceanbase.oms.connector.coordinator.BootStrapPanel.boot(BootStrapPanel.java:240) 963 at com.oceanbase.oms.connector.jdbc.coordinator.Bootstrap.main(Bootstrap.java:44) 964 Caused by: java.lang.RuntimeException: Illegal format, can not read version 965 at com.pingcap.ticdc.cdc.TicdcEventDecoder.readKeyVersion(TicdcEventDecoder.java:117) 966 at com.pingcap.ticdc.cdc.TicdcEventDecoder.(TicdcEventDecoder.java:85) 967 at com.oceanbase.oms.connector.source.kafka.tidb.TiDBCdcOpenProtocolResolver.resolveCheckpoint(TiDBCdcOpenProtocolResolver.java:95) 968 at com.oceanbase.oms.connector.source.kafka.KafkaClient.getOffset(KafkaClient.java:181) 969 at com.oceanbase.oms.connector.source.kafka.KafkaClient.getAllOffset(KafkaClient.java:145) 970 at com.oceanbase.oms.connector.source.kafka.KafkaClient.init(KafkaClient.java:57) 971 at com.oceanbase.oms.connector.source.kafka.KafkaSource.initialize(KafkaSource.java:69) 972 at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:85) 973 ... 4 common frames omitted 974 Caused by: java.io.EOFException: null 975 at java.io.DataInputStream.readFully(DataInputStream.java:197) 976 at java.io.DataInputStream.readLong(DataInputStream.java:416) 977 at com.pingcap.ticdc.cdc.TicdcEventDecoder.readKeyVersion(TicdcEventDecoder.java:115) 978 ... 11 common frames omitted 979 [2025-08-25 17:21:05.751] [ERROR] [main] [main thread error] 980 java.lang.RuntimeException: java.lang.RuntimeException: Illegal format, can not read version 981 at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:93) 982 at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:31) 983 at com.oceanbase.connector.framework.threadmanager.TaskManager.start(TaskManager.java:49) 984 at com.oceanbase.oms.connector.coordinator.BootStrapPanel.boot(BootStrapPanel.java:240) 985 at com.oceanbase.oms.connector.jdbc.coordinator.Bootstrap.main(Bootstrap.java:44) 986 Caused by: java.lang.RuntimeException: Illegal format, can not read version 987 at com.pingcap.ticdc.cdc.TicdcEventDecoder.readKeyVersion(TicdcEventDecoder.java:117) 988 at com.pingcap.ticdc.cdc.TicdcEventDecoder.(TicdcEventDecoder.java:85) 989 at com.oceanbase.oms.connector.source.kafka.tidb.TiDBCdcOpenProtocolResolver.resolveCheckpoint(TiDBCdcOpenProtocolResolver.java:95) 990 at com.oceanbase.oms.connector.source.kafka.KafkaClient.getOffset(KafkaClient.java:181) 991 at com.oceanbase.oms.connector.source.kafka.KafkaClient.getAllOffset(KafkaClient.java:145) 992 at com.oceanbase.oms.connector.source.kafka.KafkaClient.init(KafkaClient.java:57) 993 at com.oceanbase.oms.connector.source.kafka.KafkaSource.initialize(KafkaSource.java:69) 994 at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:85) 995 ... 4 common frames omitted 996 Caused by: java.io.EOFException: null 997 at java.io.DataInputStream.readFully(DataInputStream.java:197) 998 at java.io.DataInputStream.readLong(DataInputStream.java:416) 999 at com.pingcap.ticdc.cdc.TicdcEventDecoder.readKeyVersion(TicdcEventDecoder.java:115) 1000 ... 11 common frames omitted