[2025-09-16 16:02:32.648] [INFO] [main] [NativeFSLock: acquire with pid [30268]] [2025-09-16 16:02:32.655] [INFO] [main] [error file not exists] [2025-09-16 16:02:32.671] [INFO] [main] [system default timezone : GMT+08:00] [2025-09-16 16:02:32.832] [INFO] [main] [build condition cache, caseInsensitive: true, condition : { "DefaultConnectorCondition" : { "blackCondition" : "[{\"all\":false,\"sub\":[{\"func\":\"fn\",\"name\":\"drc_txn*\"},{\"func\":\"fn\",\"name\":\"DRC_TXN*\"},{\"func\":\"fn\",\"name\":\"delay_delete_*\"},{\"func\":\"fn\",\"name\":\"DELAY_DELETE_*\"}],\"func\":\"fn\",\"name\":\"pre.jiuyang_system\",\"map\":\"jiuyang_business\"}]", "whiteCondition" : "[{\"all\":false,\"sub\":[{\"name\":\"sys_store\",\"map\":\"sys_store\"},{\"name\":\"sys_enterprise\",\"map\":\"sys_enterprise\"}],\"name\":\"pre.jiuyang_system\",\"map\":\"jiuyang_business\"}]" } }] [2025-09-16 16:02:32.860] [INFO] [main] [map source class [com.oceanbase.oms.connector.source.store.MultiStoreSourceBooster] to [com.oceanbase.oms.connector.source.store.MultiStoreSourceBooster]] [2025-09-16 16:02:32.862] [INFO] [main] [map sink class [com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSinkBooster] to [com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSinkBooster]] [2025-09-16 16:02:32.870] [WARN] [main] [MySQL not determinate utf8mb4 support or not] [2025-09-16 16:02:32.870] [WARN] [main] [MySQL not determinate utf8mb4 support or not] [2025-09-16 16:02:32.898] [INFO] [main] [auto set coordinator config: {bridgeQueueSize=64, throttleMemoryBound=1073741824} by metrics MID] [2025-09-16 16:02:32.902] [INFO] [main] [auto set source config: {sourceBatchMemorySize=16777216, splitThreshold=64} by metrics MID] [2025-09-16 16:02:32.918] [INFO] [main] [CastConfig: com.oceanbase.oms.connector.common.cast.CastConfig@477b4cdf] [2025-09-16 16:02:32.930] [INFO] [main] [OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0-null-null is not valid] [2025-09-16 16:02:32.931] [INFO] [main] [[condition]] [2025-09-16 16:02:32.931] [INFO] [main] [ blackCondition = [{"all":false,"sub":[{"func":"fn","name":"drc_txn*"},{"func":"fn","name":"DRC_TXN*"},{"func":"fn","name":"delay_delete_*"},{"func":"fn","name":"DELAY_DELETE_*"}],"func":"fn","name":"pre.jiuyang_system","map":"jiuyang_business"}]] [2025-09-16 16:02:32.931] [INFO] [main] [ whiteCondition = [{"all":false,"sub":[{"name":"sys_store","map":"sys_store"},{"name":"sys_enterprise","map":"sys_enterprise"}],"name":"pre.jiuyang_system","map":"jiuyang_business"}]] [2025-09-16 16:02:32.931] [INFO] [main] [[coordinator]] [2025-09-16 16:02:32.931] [INFO] [main] [ taskIdentity = np_72zt6yn658v4] [2025-09-16 16:02:32.931] [INFO] [main] [ enableOmsConnectorV2Report = true] [2025-09-16 16:02:32.931] [INFO] [main] [ isCaseSensitive = false] [2025-09-16 16:02:32.931] [INFO] [main] [ dbTableCaseStrategy = follow-source] [2025-09-16 16:02:32.932] [INFO] [main] [ streamMode = true] [2025-09-16 16:02:32.932] [INFO] [main] [ timezone = +08:00] [2025-09-16 16:02:32.932] [INFO] [main] [ enableActiveReportTask = false] [2025-09-16 16:02:32.932] [INFO] [main] [ bridgeQueueSize = 64] [2025-09-16 16:02:32.932] [INFO] [main] [ ignoreDdl = false] [2025-09-16 16:02:32.932] [INFO] [main] [ enableMetricReportTask = false] [2025-09-16 16:02:32.932] [INFO] [main] [ sourceType = OB_MYSQL] [2025-09-16 16:02:32.932] [INFO] [main] [ columnCaseStrategy = follow-source] [2025-09-16 16:02:32.932] [INFO] [main] [ throttleMemoryBound = 1073741824] [2025-09-16 16:02:32.932] [INFO] [main] [ sinkType = OB_MYSQL] [2025-09-16 16:02:32.932] [INFO] [main] [ listenPort = 16001] [2025-09-16 16:02:32.932] [INFO] [main] [ allowRecordTypes = DELETE,INSERT,UPDATE,DDL] [2025-09-16 16:02:32.932] [INFO] [main] [ ignoreCompensateDDL = false] [2025-09-16 16:02:32.932] [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] [2025-09-16 16:02:32.932] [INFO] [main] [[sink]] [2025-09-16 16:02:32.933] [INFO] [main] [ boosterClass = com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSinkBooster] [2025-09-16 16:02:32.933] [INFO] [main] [ timezone = +08:00] [2025-09-16 16:02:32.933] [INFO] [main] [ filterHiddenPK = false] [2025-09-16 16:02:32.933] [INFO] [main] [ isPreLoadAllTableSchema = false] [2025-09-16 16:02:32.933] [INFO] [main] [ type = JDBC_SINK_OB_MYSQL] [2025-09-16 16:02:32.933] [INFO] [main] [ ignoreDdl = false] [2025-09-16 16:02:32.933] [INFO] [main] [ ignoreConflictDetectOfNullValue = true] [2025-09-16 16:02:32.933] [INFO] [main] [ password = PreP123!@#] [2025-09-16 16:02:32.933] [INFO] [main] [ columnCaseStrategy = follow-source] [2025-09-16 16:02:32.933] [INFO] [main] [ sinkMaps = [["jiuyang_business","sys_enterprise"],["jiuyang_business","sys_store"]]] [2025-09-16 16:02:32.933] [INFO] [main] [ jar = jdbc-sink-ob-mysql.jar] [2025-09-16 16:02:32.933] [INFO] [main] [ tenant = pre] [2025-09-16 16:02:32.933] [INFO] [main] [ enableNoUniqueConstraintTableReplicate = false] [2025-09-16 16:02:32.933] [INFO] [main] [ dbTableCaseStrategy = follow-source] [2025-09-16 16:02:32.933] [INFO] [main] [ dbVersion = 4.3.1.0] [2025-09-16 16:02:32.933] [INFO] [main] [ endpointId = e_72z412weyzsw] [2025-09-16 16:02:32.933] [INFO] [main] [ sourceIsStore = true] [2025-09-16 16:02:32.933] [INFO] [main] [ insertMode = INSERT] [2025-09-16 16:02:32.933] [INFO] [main] [ charsetReplaceMap = {}] [2025-09-16 16:02:32.933] [INFO] [main] [ sourceType = OB_MYSQL] [2025-09-16 16:02:32.933] [INFO] [main] [ jdbcUrl = jdbc:mysql://199.16.3.52:2883?useUnicode=true&allowMultiQueries=true&socketTimeout=50000&characterEncoding=utf8&readOnlyPropagatesToServer=false] [2025-09-16 16:02:32.933] [INFO] [main] [ ignoreRedunantColumnsReplicate = false] [2025-09-16 16:02:32.933] [INFO] [main] [ workerNum = 4] [2025-09-16 16:02:32.933] [INFO] [main] [ sinkType = OB_MYSQL] [2025-09-16 16:02:32.933] [INFO] [main] [ username = root@pre] [2025-09-16 16:02:32.933] [INFO] [main] [[source]] [2025-09-16 16:02:32.934] [INFO] [main] [ checkpoint = {"OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0":"1758009535"}] [2025-09-16 16:02:32.934] [INFO] [main] [ boosterClass = com.oceanbase.oms.connector.source.store.MultiStoreSourceBooster] [2025-09-16 16:02:32.934] [INFO] [main] [ taskIdentity = np_72zt6yn658v4] [2025-09-16 16:02:32.934] [INFO] [main] [ enableOmsConnectorV2Report = true] [2025-09-16 16:02:32.934] [INFO] [main] [ clients = [{"clientId":"OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0","clusterManagerUrl":"http://199.16.3.15:8088","subtopic":"OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0"}]] [2025-09-16 16:02:32.934] [INFO] [main] [ enableNoUniqueConstraintTableReplicate = false] [2025-09-16 16:02:32.934] [INFO] [main] [ dbVersion = 4.3.1.0] [2025-09-16 16:02:32.934] [INFO] [main] [ timezone = +08:00] [2025-09-16 16:02:32.934] [INFO] [main] [ dbType = OB_MYSQL] [2025-09-16 16:02:32.934] [INFO] [main] [ taskSubId = 1] [2025-09-16 16:02:32.934] [INFO] [main] [ type = STORE_SOURCE] [2025-09-16 16:02:32.934] [INFO] [main] [ sourceBatchMemorySize = 16777216] [2025-09-16 16:02:32.934] [INFO] [main] [ ignoreDdl = false] [2025-09-16 16:02:32.934] [INFO] [main] [ password = RM_oms] [2025-09-16 16:02:32.934] [INFO] [main] [ taskType = migrate] [2025-09-16 16:02:32.934] [INFO] [main] [ jar = connector-source-store.jar] [2025-09-16 16:02:32.934] [INFO] [main] [ workerNum = 4] [2025-09-16 16:02:32.934] [INFO] [main] [ username = RM_oms] [2025-09-16 16:02:32.934] [INFO] [main] [ splitThreshold = 64] [2025-09-16 16:02:32.975] [INFO] [main] [store config: { "checkpoint" : "{\"OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0\":\"1758009535\"}", "boosterClass" : "com.oceanbase.oms.connector.source.store.MultiStoreSourceBooster", "taskIdentity" : "np_72zt6yn658v4", "enableOmsConnectorV2Report" : "true", "clients" : "[{\"clientId\":\"OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0\",\"clusterManagerUrl\":\"http://199.16.3.15:8088\",\"subtopic\":\"OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0\"}]", "enableNoUniqueConstraintTableReplicate" : "false", "dbVersion" : "4.3.1.0", "timezone" : "+08:00", "dbType" : "OB_MYSQL", "taskSubId" : "1", "type" : "STORE_SOURCE", "sourceBatchMemorySize" : "16777216", "connectionTimeoutSec" : "120", "ignoreDdl" : "false", "askSelfUnit" : "false", "password" : "RM_oms", "taskType" : "migrate", "maxRetries" : "1000", "transactionEnabled" : "false", "jar" : "connector-source-store.jar", "workerNum" : "4", "username" : "RM_oms", "splitThreshold" : "64" }] [2025-09-16 16:02:33.287] [INFO] [main] [[Init DruidDataSource]sessionParameters: {}] [2025-09-16 16:02:33.287] [INFO] [main] [199.16.3.52:2883 root@pre init sql:set foreign_key_checks = off] [2025-09-16 16:02:33.288] [INFO] [main] [init druid dataSource with loginTimeout[300], maxWaitMillis[12000], maxActive[4], initActive[4], minIdle[4]] [2025-09-16 16:02:33.289] [INFO] [main] [connect with url [jdbc:mysql://199.16.3.52:2883?readOnlyPropagatesToServer=false&useUnicode=true&rewriteBatchedStatements=true&socketTimeout=50000&connectTimeout=30000&allowMultiQueries=true&characterEncoding=utf8&netTimeoutForStreamingResults=28800&useSSL=false]] [2025-09-16 16:02:33.289] [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 199.16.3.52:2883 user root@pre characterSet ] [2025-09-16 16:02:33.308] [INFO] [main] [[Init DruidDataSource]sessionParameters: {}] [2025-09-16 16:02:33.308] [INFO] [main] [199.16.3.52:2883 root@pre init sql:set foreign_key_checks = off] [2025-09-16 16:02:33.308] [INFO] [main] [init druid dataSource with loginTimeout[300], maxWaitMillis[12000], maxActive[3], initActive[0], minIdle[0]] [2025-09-16 16:02:33.309] [INFO] [main] [connect with url [jdbc:mysql://199.16.3.52:2883?readOnlyPropagatesToServer=false&useUnicode=true&rewriteBatchedStatements=true&socketTimeout=172800000&connectTimeout=30000&allowMultiQueries=true&characterEncoding=utf8&netTimeoutForStreamingResults=28800&useSSL=false]] [2025-09-16 16:02:33.309] [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 199.16.3.52:2883 user root@pre characterSet ] [2025-09-16 16:02:33.517] [INFO] [main] [{dataSource-1} inited] [2025-09-16 16:02:33.743] [INFO] [main] [SHOW VARIABLES LIKE 'version_comment'] [2025-09-16 16:02:33.747] [INFO] [main] [sink db version:4.3.1.0] [2025-09-16 16:02:33.877] [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] [2025-09-16 16:02:33.885] [INFO] [main] [put coordinator.maxRecordCapacity: batchSize(64), workerNum(4), maxRecordCapacity: 16384, may have been set, so it's inconsistent with cal value ] [2025-09-16 16:02:33.956] [INFO] [main] [MatchDDLConfig: ] [2025-09-16 16:02:34.005] [INFO] [main] [ConcurrentArrayQueue mod MULTI_PRODUCER_MULTI_CONSUMER, size: 64] [2025-09-16 16:02:34.010] [INFO] [main] [ConcurrentArrayQueue mod MULTI_PRODUCER_MULTI_CONSUMER, size: 64] [2025-09-16 16:02:34.022] [INFO] [main] [[condition]] [2025-09-16 16:02:34.023] [INFO] [main] [ blackCondition = [{"all":false,"sub":[{"func":"fn","name":"drc_txn*"},{"func":"fn","name":"DRC_TXN*"},{"func":"fn","name":"delay_delete_*"},{"func":"fn","name":"DELAY_DELETE_*"}],"func":"fn","name":"pre.jiuyang_system","map":"jiuyang_business"}]] [2025-09-16 16:02:34.023] [INFO] [main] [ whiteCondition = [{"all":false,"sub":[{"name":"sys_store","map":"sys_store"},{"name":"sys_enterprise","map":"sys_enterprise"}],"name":"pre.jiuyang_system","map":"jiuyang_business"}]] [2025-09-16 16:02:34.023] [INFO] [main] [[coordinator]] [2025-09-16 16:02:34.023] [INFO] [main] [ taskIdentity = np_72zt6yn658v4] [2025-09-16 16:02:34.023] [INFO] [main] [ enableOmsConnectorV2Report = true] [2025-09-16 16:02:34.023] [INFO] [main] [ isCaseSensitive = false] [2025-09-16 16:02:34.023] [INFO] [main] [ dbTableCaseStrategy = follow-source] [2025-09-16 16:02:34.023] [INFO] [main] [ streamMode = true] [2025-09-16 16:02:34.023] [INFO] [main] [ maxRecordCapacity = 16384] [2025-09-16 16:02:34.023] [INFO] [main] [ timezone = +08:00] [2025-09-16 16:02:34.023] [INFO] [main] [ enableActiveReportTask = false] [2025-09-16 16:02:34.023] [INFO] [main] [ bridgeQueueSize = 64] [2025-09-16 16:02:34.023] [INFO] [main] [ ignoreDdl = false] [2025-09-16 16:02:34.023] [INFO] [main] [ enableMetricReportTask = false] [2025-09-16 16:02:34.023] [INFO] [main] [ sourceType = OB_MYSQL] [2025-09-16 16:02:34.023] [INFO] [main] [ columnCaseStrategy = follow-source] [2025-09-16 16:02:34.023] [INFO] [main] [ throttleMemoryBound = 1073741824] [2025-09-16 16:02:34.023] [INFO] [main] [ sinkType = OB_MYSQL] [2025-09-16 16:02:34.023] [INFO] [main] [ dispatcherClassName = com.oceanbase.oms.connector.dispatcher.scheduler.DefaultTransactionScheduler] [2025-09-16 16:02:34.023] [INFO] [main] [ listenPort = 16001] [2025-09-16 16:02:34.023] [INFO] [main] [ allowRecordTypes = DELETE,INSERT,UPDATE,DDL] [2025-09-16 16:02:34.023] [INFO] [main] [ ignoreCompensateDDL = false] [2025-09-16 16:02:34.023] [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] [2025-09-16 16:02:34.023] [INFO] [main] [[sink]] [2025-09-16 16:02:34.023] [INFO] [main] [ boosterClass = com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSinkBooster] [2025-09-16 16:02:34.023] [INFO] [main] [ timezone = +08:00] [2025-09-16 16:02:34.023] [INFO] [main] [ filterHiddenPK = false] [2025-09-16 16:02:34.023] [INFO] [main] [ isPreLoadAllTableSchema = false] [2025-09-16 16:02:34.024] [INFO] [main] [ type = JDBC_SINK_OB_MYSQL] [2025-09-16 16:02:34.024] [INFO] [main] [ ignoreDdl = false] [2025-09-16 16:02:34.024] [INFO] [main] [ ignoreConflictDetectOfNullValue = true] [2025-09-16 16:02:34.024] [INFO] [main] [ password = PreP123!@#] [2025-09-16 16:02:34.024] [INFO] [main] [ columnCaseStrategy = default] [2025-09-16 16:02:34.024] [INFO] [main] [ sinkMaps = [["jiuyang_business","sys_enterprise"],["jiuyang_business","sys_store"]]] [2025-09-16 16:02:34.024] [INFO] [main] [ jar = jdbc-sink-ob-mysql.jar] [2025-09-16 16:02:34.024] [INFO] [main] [ enableTransactionWriter = true] [2025-09-16 16:02:34.024] [INFO] [main] [ supportedTimezone = []] [2025-09-16 16:02:34.024] [INFO] [main] [ tenant = pre] [2025-09-16 16:02:34.024] [INFO] [main] [ enableNoUniqueConstraintTableReplicate = false] [2025-09-16 16:02:34.024] [INFO] [main] [ dbTableCaseStrategy = default] [2025-09-16 16:02:34.024] [INFO] [main] [ dbVersion = 4.3.1.0] [2025-09-16 16:02:34.024] [INFO] [main] [ endpointId = e_72z412weyzsw] [2025-09-16 16:02:34.024] [INFO] [main] [ sourceIsStore = true] [2025-09-16 16:02:34.024] [INFO] [main] [ insertMode = INSERT] [2025-09-16 16:02:34.024] [INFO] [main] [ charsetReplaceMap = {}] [2025-09-16 16:02:34.024] [INFO] [main] [ sourceType = OB_MYSQL] [2025-09-16 16:02:34.024] [INFO] [main] [ jdbcUrl = jdbc:mysql://199.16.3.52:2883?useUnicode=true&allowMultiQueries=true&socketTimeout=50000&characterEncoding=utf8&readOnlyPropagatesToServer=false] [2025-09-16 16:02:34.024] [INFO] [main] [ ignoreRedunantColumnsReplicate = false] [2025-09-16 16:02:34.024] [INFO] [main] [ workerNum = 4] [2025-09-16 16:02:34.024] [INFO] [main] [ sinkType = OB_MYSQL] [2025-09-16 16:02:34.024] [INFO] [main] [ username = root@pre] [2025-09-16 16:02:34.024] [INFO] [main] [[source]] [2025-09-16 16:02:34.024] [INFO] [main] [ checkpoint = {"OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0":"1758009535"}] [2025-09-16 16:02:34.024] [INFO] [main] [ boosterClass = com.oceanbase.oms.connector.source.store.MultiStoreSourceBooster] [2025-09-16 16:02:34.024] [INFO] [main] [ taskIdentity = np_72zt6yn658v4] [2025-09-16 16:02:34.024] [INFO] [main] [ enableOmsConnectorV2Report = true] [2025-09-16 16:02:34.024] [INFO] [main] [ clients = [{"clientId":"OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0","clusterManagerUrl":"http://199.16.3.15:8088","subtopic":"OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0"}]] [2025-09-16 16:02:34.024] [INFO] [main] [ enableNoUniqueConstraintTableReplicate = false] [2025-09-16 16:02:34.024] [INFO] [main] [ dbVersion = 4.3.1.0] [2025-09-16 16:02:34.024] [INFO] [main] [ timezone = +08:00] [2025-09-16 16:02:34.024] [INFO] [main] [ dbType = OB_MYSQL] [2025-09-16 16:02:34.024] [INFO] [main] [ taskSubId = 1] [2025-09-16 16:02:34.024] [INFO] [main] [ type = STORE_SOURCE] [2025-09-16 16:02:34.024] [INFO] [main] [ sourceBatchMemorySize = 16777216] [2025-09-16 16:02:34.024] [INFO] [main] [ ignoreDdl = false] [2025-09-16 16:02:34.024] [INFO] [main] [ password = RM_oms] [2025-09-16 16:02:34.024] [INFO] [main] [ taskType = migrate] [2025-09-16 16:02:34.024] [INFO] [main] [ jar = connector-source-store.jar] [2025-09-16 16:02:34.024] [INFO] [main] [ workerNum = 4] [2025-09-16 16:02:34.024] [INFO] [main] [ username = RM_oms] [2025-09-16 16:02:34.024] [INFO] [main] [ splitThreshold = 64] [2025-09-16 16:02:34.029] [INFO] [main] [BootStrap: init memoryBoound value to 1073741824] [2025-09-16 16:02:34.035] [INFO] [main] [BootStrapPanel: register keep alive url [/status]] [2025-09-16 16:02:34.036] [INFO] [main] [BootStrapPanel: register source stats url [/source/stats]] [2025-09-16 16:02:34.037] [INFO] [main] [BootStrapPanel: register checkpoint query url [/checkpoint/query]] [2025-09-16 16:02:34.038] [INFO] [main] [BootStrapPanel: register throttle control url [/throttle/control]] [2025-09-16 16:02:34.038] [INFO] [main] [BootStrapPanel: register throttle query url [/throttle/query]] [2025-09-16 16:02:34.058] [INFO] [main] [Writer init with arguments, write mode[SEMI_BATCH_PREPARE_STATEMENT], maxTxnRetryTimes[1000], retryIntervalTime[1000],dryRun[false], printSql[false], slowSqlThreshold[15], ignoreDDL[false], hotKeyMerge[false]typeStatistics[false], fullBatchWithSameTable[false], canLobBatched[true]] [2025-09-16 16:02:34.059] [INFO] [main] [Writer init with arguments, write mode[SEMI_BATCH_PREPARE_STATEMENT], maxTxnRetryTimes[1000], retryIntervalTime[1000],dryRun[false], printSql[false], slowSqlThreshold[15], ignoreDDL[false], hotKeyMerge[false]typeStatistics[false], fullBatchWithSameTable[false], canLobBatched[true]] [2025-09-16 16:02:34.060] [INFO] [main] [Writer init with arguments, write mode[SEMI_BATCH_PREPARE_STATEMENT], maxTxnRetryTimes[1000], retryIntervalTime[1000],dryRun[false], printSql[false], slowSqlThreshold[15], ignoreDDL[false], hotKeyMerge[false]typeStatistics[false], fullBatchWithSameTable[false], canLobBatched[true]] [2025-09-16 16:02:34.060] [INFO] [main] [Writer init with arguments, write mode[SEMI_BATCH_PREPARE_STATEMENT], maxTxnRetryTimes[1000], retryIntervalTime[1000],dryRun[false], printSql[false], slowSqlThreshold[15], ignoreDDL[false], hotKeyMerge[false]typeStatistics[false], fullBatchWithSameTable[false], canLobBatched[true]] [2025-09-16 16:02:34.072] [INFO] [main] [storeSource config: {checkpoint={"OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0":"1758009535"}, useDRCNet=true, cmUrl=http://199.16.3.15:8088, storePassword=RM_oms, boosterClass=com.oceanbase.oms.connector.source.store.MultiStoreSourceBooster, enableOmsConnectorV2Report=true, clients=[{"clientId":"OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0","clusterManagerUrl":"http://199.16.3.15:8088","subtopic":"OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0"}], timezone=+08:00, storeEnableTransactionSeq=false, type=STORE_SOURCE, sourceBatchMemorySize=16777216, ignoreDdl=false, password=RM_oms, taskType=migrate, storeTimeoutSec=120, jar=connector-source-store.jar, timestamp=1758009535, taskIdentity=np_72zt6yn658v4, srcSubTopic=OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0, enableNoUniqueConstraintTableReplicate=false, clientId=OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0, dbVersion=4.3.1.0, dbType=OB_MYSQL, taskSubId=1, storeRetryTimes=1000, storeUsername=RM_oms, askSelfUnit=false, storeBlackFilterStr=pre.jiuyang_system.drc_txn*|pre.jiuyang_system.delay_delete_*, workerNum=4, storeWhiteFilterStr=pre.jiuyang_system.sys_store|pre.jiuyang_system.sys_enterprise, username=RM_oms, splitThreshold=64}] [2025-09-16 16:02:34.074] [INFO] [main] [start transaction assembler] [2025-09-16 16:02:34.074] [WARN] [main] [StoreSource: cache enabled[false]] [2025-09-16 16:02:34.081] [INFO] [main] [useCheckpointListener: true] [2025-09-16 16:02:34.098] [INFO] [main] [useSchemaCache: false, useBetaListener: false] [2025-09-16 16:02:34.098] [INFO] [main] [create drc client with config: {client.connectionTimeout=120, binlogPassword=RM_oms, subTopic=OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0, client.socketTimeout=120, askSelfUnit=false, manager.host=http://199.16.3.15:8088, client.requireCompleteTxn=false, timestamp=1758009535, binlogUsername=RM_oms, useDrcNet=true, server.messageType=binary, server.maxRetriedTimes=1000}] [2025-09-16 16:02:34.104] [INFO] [main] [Initialize the service with starting point: 1758009535] [2025-09-16 16:02:34.105] [INFO] [main] [drc client started] [2025-09-16 16:02:34.105] [INFO] [main] [store source crawler info is {crawler=null, drcConfig={subTopic=OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0, client.requireCompleteTxn=false, binlogPassword=RM_oms, server.messageType=binary, binlogUsername=RM_oms, client.connectionTimeout=120, version=2.0.0, askSelfUnit=false, useDrcNet=true, client.socketTimeout=120, server.maxRetriedTimes=1000, checkpoint.period=500, manager.host=http://199.16.3.15:8088, timestamp=1758009535}, store=null}] [2025-09-16 16:02:34.107] [INFO] [main] [start drc client] [2025-09-16 16:02:43.885] [INFO] [OBHighWatermarkMonitor_0] [{dataSource-2} inited] [2025-09-16 16:03:03.323] [ERROR] [main] [notifyStopped:] java.lang.RuntimeException: com.oceanbase.oms.store.client.HttpBadResponseException: CmBaseException(oldErrorCode=0, errMsg=Found no active stores under topic [OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0], reason=null, relativeDocs=null) at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:93) at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:31) at com.oceanbase.connector.framework.threadmanager.TaskManager.start(TaskManager.java:49) at com.oceanbase.oms.connector.coordinator.BootStrapPanel.boot(BootStrapPanel.java:240) at com.oceanbase.oms.connector.jdbc.coordinator.Bootstrap.main(Bootstrap.java:44) Caused by: com.oceanbase.oms.store.client.HttpBadResponseException: CmBaseException(oldErrorCode=0, errMsg=Found no active stores under topic [OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0], reason=null, relativeDocs=null) at com.oceanbase.oms.store.client.impl.ServerProxy.askStore(ServerProxy.java:487) at com.oceanbase.oms.store.client.impl.ClusterManagers.findStore(ClusterManagers.java:101) at com.oceanbase.oms.store.client.impl.DRCClientImpl.connectClusterManager(DRCClientImpl.java:380) at com.oceanbase.oms.store.client.impl.DRCClientImpl.startService(DRCClientImpl.java:677) at com.oceanbase.oms.connector.source.store.StoreSource.start(StoreSource.java:159) at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:86) ... 4 common frames omitted [2025-09-16 16:03:03.325] [INFO] [main] [close sourceTaskManager done] [2025-09-16 16:03:03.326] [INFO] [main] [close sourceBooster done] [2025-09-16 16:03:03.329] [INFO] [forward_slot0-(ETLProcessor)-queue_slot1] [SerialBridgeTask [forward_slot0-(ETLProcessor)-queue_slot1] stopped] [2025-09-16 16:03:03.333] [INFO] [queue_slot1-()-TransactionScheduler] [SerialBridgeTask [queue_slot1-()-TransactionScheduler] stopped] [2025-09-16 16:03:03.333] [INFO] [main] [close bridgeTaskManager done] [2025-09-16 16:03:03.336] [INFO] [sinkTask-0] [SyncSinkTask [sinkTask-0] stopped] [2025-09-16 16:03:03.336] [INFO] [sinkTask-0] [{dataSource-1} closing ...] [2025-09-16 16:03:03.339] [INFO] [sinkTask-0] [{dataSource-1} closed] [2025-09-16 16:03:03.339] [INFO] [sinkTask-0] [{dataSource-2} closing ...] [2025-09-16 16:03:03.340] [INFO] [sinkTask-0] [{dataSource-2} closed] [2025-09-16 16:03:03.341] [INFO] [sinkTask-1] [SyncSinkTask [sinkTask-1] stopped] [2025-09-16 16:03:03.346] [INFO] [sinkTask-2] [SyncSinkTask [sinkTask-2] stopped] [2025-09-16 16:03:03.346] [INFO] [sinkTask-3] [SyncSinkTask [sinkTask-3] stopped] [2025-09-16 16:03:03.346] [INFO] [main] [close sinkTaskManager done] [2025-09-16 16:03:03.347] [INFO] [main] [close sinkBooster done] [2025-09-16 16:03:03.347] [INFO] [main] [close frameworkCustomize done] [2025-09-16 16:03:03.347] [INFO] [main] [close reporter done] [2025-09-16 16:03:03.347] [INFO] [main] [close httpServer done] [2025-09-16 16:03:03.347] [INFO] [main] [close timerTaskScheduler done] [2025-09-16 16:03:03.347] [WARN] [main] [FrameWork exist {}] java.lang.RuntimeException: com.oceanbase.oms.store.client.HttpBadResponseException: CmBaseException(oldErrorCode=0, errMsg=Found no active stores under topic [OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0], reason=null, relativeDocs=null) at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:93) at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:31) at com.oceanbase.connector.framework.threadmanager.TaskManager.start(TaskManager.java:49) at com.oceanbase.oms.connector.coordinator.BootStrapPanel.boot(BootStrapPanel.java:240) at com.oceanbase.oms.connector.jdbc.coordinator.Bootstrap.main(Bootstrap.java:44) Caused by: com.oceanbase.oms.store.client.HttpBadResponseException: CmBaseException(oldErrorCode=0, errMsg=Found no active stores under topic [OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0], reason=null, relativeDocs=null) at com.oceanbase.oms.store.client.impl.ServerProxy.askStore(ServerProxy.java:487) at com.oceanbase.oms.store.client.impl.ClusterManagers.findStore(ClusterManagers.java:101) at com.oceanbase.oms.store.client.impl.DRCClientImpl.connectClusterManager(DRCClientImpl.java:380) at com.oceanbase.oms.store.client.impl.DRCClientImpl.startService(DRCClientImpl.java:677) at com.oceanbase.oms.connector.source.store.StoreSource.start(StoreSource.java:159) at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:86) ... 4 common frames omitted [2025-09-16 16:03:04.892] [ERROR] [main] [main thread error] java.lang.RuntimeException: com.oceanbase.oms.store.client.HttpBadResponseException: CmBaseException(oldErrorCode=0, errMsg=Found no active stores under topic [OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0], reason=null, relativeDocs=null) at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:93) at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:31) at com.oceanbase.connector.framework.threadmanager.TaskManager.start(TaskManager.java:49) at com.oceanbase.oms.connector.coordinator.BootStrapPanel.boot(BootStrapPanel.java:240) at com.oceanbase.oms.connector.jdbc.coordinator.Bootstrap.main(Bootstrap.java:44) Caused by: com.oceanbase.oms.store.client.HttpBadResponseException: CmBaseException(oldErrorCode=0, errMsg=Found no active stores under topic [OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0], reason=null, relativeDocs=null) at com.oceanbase.oms.store.client.impl.ServerProxy.askStore(ServerProxy.java:487) at com.oceanbase.oms.store.client.impl.ClusterManagers.findStore(ClusterManagers.java:101) at com.oceanbase.oms.store.client.impl.DRCClientImpl.connectClusterManager(DRCClientImpl.java:380) at com.oceanbase.oms.store.client.impl.DRCClientImpl.startService(DRCClientImpl.java:677) at com.oceanbase.oms.connector.source.store.StoreSource.start(StoreSource.java:159) at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:86) ... 4 common frames omitted [2025-09-16 16:29:34.363] [INFO] [main] [NativeFSLock: acquire with pid [92676]] [2025-09-16 16:29:34.368] [INFO] [main] [error file not exists] [2025-09-16 16:29:34.387] [INFO] [main] [system default timezone : GMT+08:00] [2025-09-16 16:29:34.551] [INFO] [main] [build condition cache, caseInsensitive: true, condition : { "DefaultConnectorCondition" : { "blackCondition" : "[{\"all\":false,\"sub\":[{\"func\":\"fn\",\"name\":\"drc_txn*\"},{\"func\":\"fn\",\"name\":\"DRC_TXN*\"},{\"func\":\"fn\",\"name\":\"delay_delete_*\"},{\"func\":\"fn\",\"name\":\"DELAY_DELETE_*\"}],\"func\":\"fn\",\"name\":\"pre.jiuyang_system\",\"map\":\"jiuyang_business\"}]", "whiteCondition" : "[{\"all\":false,\"sub\":[{\"name\":\"sys_store\",\"map\":\"sys_store\"},{\"name\":\"sys_enterprise\",\"map\":\"sys_enterprise\"}],\"name\":\"pre.jiuyang_system\",\"map\":\"jiuyang_business\"}]" } }] [2025-09-16 16:29:34.579] [INFO] [main] [map source class [com.oceanbase.oms.connector.source.store.MultiStoreSourceBooster] to [com.oceanbase.oms.connector.source.store.MultiStoreSourceBooster]] [2025-09-16 16:29:34.581] [INFO] [main] [map sink class [com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSinkBooster] to [com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSinkBooster]] [2025-09-16 16:29:34.590] [WARN] [main] [MySQL not determinate utf8mb4 support or not] [2025-09-16 16:29:34.590] [WARN] [main] [MySQL not determinate utf8mb4 support or not] [2025-09-16 16:29:34.618] [INFO] [main] [auto set coordinator config: {bridgeQueueSize=64, throttleMemoryBound=1073741824} by metrics MID] [2025-09-16 16:29:34.622] [INFO] [main] [auto set source config: {sourceBatchMemorySize=16777216, splitThreshold=64} by metrics MID] [2025-09-16 16:29:34.640] [INFO] [main] [CastConfig: com.oceanbase.oms.connector.common.cast.CastConfig@477b4cdf] [2025-09-16 16:29:34.654] [INFO] [main] [OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0-null-null is not valid] [2025-09-16 16:29:34.654] [INFO] [main] [[condition]] [2025-09-16 16:29:34.654] [INFO] [main] [ blackCondition = [{"all":false,"sub":[{"func":"fn","name":"drc_txn*"},{"func":"fn","name":"DRC_TXN*"},{"func":"fn","name":"delay_delete_*"},{"func":"fn","name":"DELAY_DELETE_*"}],"func":"fn","name":"pre.jiuyang_system","map":"jiuyang_business"}]] [2025-09-16 16:29:34.655] [INFO] [main] [ whiteCondition = [{"all":false,"sub":[{"name":"sys_store","map":"sys_store"},{"name":"sys_enterprise","map":"sys_enterprise"}],"name":"pre.jiuyang_system","map":"jiuyang_business"}]] [2025-09-16 16:29:34.655] [INFO] [main] [[coordinator]] [2025-09-16 16:29:34.655] [INFO] [main] [ taskIdentity = np_72zt6yn658v4] [2025-09-16 16:29:34.655] [INFO] [main] [ enableOmsConnectorV2Report = true] [2025-09-16 16:29:34.655] [INFO] [main] [ isCaseSensitive = false] [2025-09-16 16:29:34.655] [INFO] [main] [ dbTableCaseStrategy = follow-source] [2025-09-16 16:29:34.655] [INFO] [main] [ streamMode = true] [2025-09-16 16:29:34.655] [INFO] [main] [ timezone = +08:00] [2025-09-16 16:29:34.655] [INFO] [main] [ enableActiveReportTask = false] [2025-09-16 16:29:34.655] [INFO] [main] [ bridgeQueueSize = 64] [2025-09-16 16:29:34.655] [INFO] [main] [ ignoreDdl = false] [2025-09-16 16:29:34.655] [INFO] [main] [ enableMetricReportTask = false] [2025-09-16 16:29:34.655] [INFO] [main] [ sourceType = OB_MYSQL] [2025-09-16 16:29:34.655] [INFO] [main] [ columnCaseStrategy = follow-source] [2025-09-16 16:29:34.655] [INFO] [main] [ throttleMemoryBound = 1073741824] [2025-09-16 16:29:34.655] [INFO] [main] [ sinkType = OB_MYSQL] [2025-09-16 16:29:34.655] [INFO] [main] [ listenPort = 16000] [2025-09-16 16:29:34.655] [INFO] [main] [ allowRecordTypes = DELETE,INSERT,UPDATE,DDL] [2025-09-16 16:29:34.655] [INFO] [main] [ ignoreCompensateDDL = false] [2025-09-16 16:29:34.655] [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] [2025-09-16 16:29:34.655] [INFO] [main] [[sink]] [2025-09-16 16:29:34.656] [INFO] [main] [ boosterClass = com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSinkBooster] [2025-09-16 16:29:34.656] [INFO] [main] [ timezone = +08:00] [2025-09-16 16:29:34.656] [INFO] [main] [ filterHiddenPK = false] [2025-09-16 16:29:34.656] [INFO] [main] [ isPreLoadAllTableSchema = false] [2025-09-16 16:29:34.656] [INFO] [main] [ type = JDBC_SINK_OB_MYSQL] [2025-09-16 16:29:34.656] [INFO] [main] [ ignoreDdl = false] [2025-09-16 16:29:34.656] [INFO] [main] [ ignoreConflictDetectOfNullValue = true] [2025-09-16 16:29:34.656] [INFO] [main] [ password = PreP123!@#] [2025-09-16 16:29:34.656] [INFO] [main] [ columnCaseStrategy = follow-source] [2025-09-16 16:29:34.656] [INFO] [main] [ sinkMaps = [["jiuyang_business","sys_enterprise"],["jiuyang_business","sys_store"]]] [2025-09-16 16:29:34.656] [INFO] [main] [ jar = jdbc-sink-ob-mysql.jar] [2025-09-16 16:29:34.656] [INFO] [main] [ tenant = pre] [2025-09-16 16:29:34.656] [INFO] [main] [ enableNoUniqueConstraintTableReplicate = false] [2025-09-16 16:29:34.656] [INFO] [main] [ dbTableCaseStrategy = follow-source] [2025-09-16 16:29:34.656] [INFO] [main] [ dbVersion = 4.3.1.0] [2025-09-16 16:29:34.656] [INFO] [main] [ endpointId = e_72z412weyzsw] [2025-09-16 16:29:34.656] [INFO] [main] [ sourceIsStore = true] [2025-09-16 16:29:34.656] [INFO] [main] [ insertMode = INSERT] [2025-09-16 16:29:34.656] [INFO] [main] [ charsetReplaceMap = {}] [2025-09-16 16:29:34.657] [INFO] [main] [ sourceType = OB_MYSQL] [2025-09-16 16:29:34.657] [INFO] [main] [ jdbcUrl = jdbc:mysql://199.16.3.52:2883?useUnicode=true&allowMultiQueries=true&socketTimeout=50000&characterEncoding=utf8&readOnlyPropagatesToServer=false] [2025-09-16 16:29:34.657] [INFO] [main] [ ignoreRedunantColumnsReplicate = false] [2025-09-16 16:29:34.657] [INFO] [main] [ workerNum = 4] [2025-09-16 16:29:34.657] [INFO] [main] [ sinkType = OB_MYSQL] [2025-09-16 16:29:34.657] [INFO] [main] [ username = root@pre] [2025-09-16 16:29:34.657] [INFO] [main] [[source]] [2025-09-16 16:29:34.657] [INFO] [main] [ checkpoint = {"OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0":"1758009535"}] [2025-09-16 16:29:34.657] [INFO] [main] [ boosterClass = com.oceanbase.oms.connector.source.store.MultiStoreSourceBooster] [2025-09-16 16:29:34.657] [INFO] [main] [ taskIdentity = np_72zt6yn658v4] [2025-09-16 16:29:34.657] [INFO] [main] [ enableOmsConnectorV2Report = true] [2025-09-16 16:29:34.657] [INFO] [main] [ clients = [{"clientId":"OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0","clusterManagerUrl":"http://199.16.3.15:8088","subtopic":"OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0"}]] [2025-09-16 16:29:34.657] [INFO] [main] [ enableNoUniqueConstraintTableReplicate = false] [2025-09-16 16:29:34.657] [INFO] [main] [ dbVersion = 4.3.1.0] [2025-09-16 16:29:34.657] [INFO] [main] [ timezone = +08:00] [2025-09-16 16:29:34.657] [INFO] [main] [ dbType = OB_MYSQL] [2025-09-16 16:29:34.657] [INFO] [main] [ taskSubId = 1] [2025-09-16 16:29:34.657] [INFO] [main] [ type = STORE_SOURCE] [2025-09-16 16:29:34.657] [INFO] [main] [ sourceBatchMemorySize = 16777216] [2025-09-16 16:29:34.657] [INFO] [main] [ ignoreDdl = false] [2025-09-16 16:29:34.657] [INFO] [main] [ password = RM_oms] [2025-09-16 16:29:34.657] [INFO] [main] [ taskType = migrate] [2025-09-16 16:29:34.657] [INFO] [main] [ jar = connector-source-store.jar] [2025-09-16 16:29:34.657] [INFO] [main] [ workerNum = 4] [2025-09-16 16:29:34.657] [INFO] [main] [ username = RM_oms] [2025-09-16 16:29:34.658] [INFO] [main] [ splitThreshold = 64] [2025-09-16 16:29:34.698] [INFO] [main] [store config: { "checkpoint" : "{\"OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0\":\"1758009535\"}", "boosterClass" : "com.oceanbase.oms.connector.source.store.MultiStoreSourceBooster", "taskIdentity" : "np_72zt6yn658v4", "enableOmsConnectorV2Report" : "true", "clients" : "[{\"clientId\":\"OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0\",\"clusterManagerUrl\":\"http://199.16.3.15:8088\",\"subtopic\":\"OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0\"}]", "enableNoUniqueConstraintTableReplicate" : "false", "dbVersion" : "4.3.1.0", "timezone" : "+08:00", "dbType" : "OB_MYSQL", "taskSubId" : "1", "type" : "STORE_SOURCE", "sourceBatchMemorySize" : "16777216", "connectionTimeoutSec" : "120", "ignoreDdl" : "false", "askSelfUnit" : "false", "password" : "RM_oms", "taskType" : "migrate", "maxRetries" : "1000", "transactionEnabled" : "false", "jar" : "connector-source-store.jar", "workerNum" : "4", "username" : "RM_oms", "splitThreshold" : "64" }] [2025-09-16 16:29:35.010] [INFO] [main] [[Init DruidDataSource]sessionParameters: {}] [2025-09-16 16:29:35.010] [INFO] [main] [199.16.3.52:2883 root@pre init sql:set foreign_key_checks = off] [2025-09-16 16:29:35.010] [INFO] [main] [init druid dataSource with loginTimeout[300], maxWaitMillis[12000], maxActive[4], initActive[4], minIdle[4]] [2025-09-16 16:29:35.011] [INFO] [main] [connect with url [jdbc:mysql://199.16.3.52:2883?readOnlyPropagatesToServer=false&useUnicode=true&rewriteBatchedStatements=true&socketTimeout=50000&connectTimeout=30000&allowMultiQueries=true&characterEncoding=utf8&netTimeoutForStreamingResults=28800&useSSL=false]] [2025-09-16 16:29:35.011] [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 199.16.3.52:2883 user root@pre characterSet ] [2025-09-16 16:29:35.032] [INFO] [main] [[Init DruidDataSource]sessionParameters: {}] [2025-09-16 16:29:35.032] [INFO] [main] [199.16.3.52:2883 root@pre init sql:set foreign_key_checks = off] [2025-09-16 16:29:35.032] [INFO] [main] [init druid dataSource with loginTimeout[300], maxWaitMillis[12000], maxActive[3], initActive[0], minIdle[0]] [2025-09-16 16:29:35.032] [INFO] [main] [connect with url [jdbc:mysql://199.16.3.52:2883?readOnlyPropagatesToServer=false&useUnicode=true&rewriteBatchedStatements=true&socketTimeout=172800000&connectTimeout=30000&allowMultiQueries=true&characterEncoding=utf8&netTimeoutForStreamingResults=28800&useSSL=false]] [2025-09-16 16:29:35.032] [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 199.16.3.52:2883 user root@pre characterSet ] [2025-09-16 16:29:35.226] [INFO] [main] [{dataSource-1} inited] [2025-09-16 16:29:35.426] [INFO] [main] [SHOW VARIABLES LIKE 'version_comment'] [2025-09-16 16:29:35.431] [INFO] [main] [sink db version:4.3.1.0] [2025-09-16 16:29:35.542] [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] [2025-09-16 16:29:35.550] [INFO] [main] [put coordinator.maxRecordCapacity: batchSize(64), workerNum(4), maxRecordCapacity: 16384, may have been set, so it's inconsistent with cal value ] [2025-09-16 16:29:35.616] [INFO] [main] [MatchDDLConfig: ] [2025-09-16 16:29:35.666] [INFO] [main] [ConcurrentArrayQueue mod MULTI_PRODUCER_MULTI_CONSUMER, size: 64] [2025-09-16 16:29:35.671] [INFO] [main] [ConcurrentArrayQueue mod MULTI_PRODUCER_MULTI_CONSUMER, size: 64] [2025-09-16 16:29:35.682] [INFO] [main] [[condition]] [2025-09-16 16:29:35.682] [INFO] [main] [ blackCondition = [{"all":false,"sub":[{"func":"fn","name":"drc_txn*"},{"func":"fn","name":"DRC_TXN*"},{"func":"fn","name":"delay_delete_*"},{"func":"fn","name":"DELAY_DELETE_*"}],"func":"fn","name":"pre.jiuyang_system","map":"jiuyang_business"}]] [2025-09-16 16:29:35.682] [INFO] [main] [ whiteCondition = [{"all":false,"sub":[{"name":"sys_store","map":"sys_store"},{"name":"sys_enterprise","map":"sys_enterprise"}],"name":"pre.jiuyang_system","map":"jiuyang_business"}]] [2025-09-16 16:29:35.682] [INFO] [main] [[coordinator]] [2025-09-16 16:29:35.682] [INFO] [main] [ taskIdentity = np_72zt6yn658v4] [2025-09-16 16:29:35.682] [INFO] [main] [ enableOmsConnectorV2Report = true] [2025-09-16 16:29:35.682] [INFO] [main] [ isCaseSensitive = false] [2025-09-16 16:29:35.682] [INFO] [main] [ dbTableCaseStrategy = follow-source] [2025-09-16 16:29:35.682] [INFO] [main] [ streamMode = true] [2025-09-16 16:29:35.682] [INFO] [main] [ maxRecordCapacity = 16384] [2025-09-16 16:29:35.682] [INFO] [main] [ timezone = +08:00] [2025-09-16 16:29:35.682] [INFO] [main] [ enableActiveReportTask = false] [2025-09-16 16:29:35.682] [INFO] [main] [ bridgeQueueSize = 64] [2025-09-16 16:29:35.682] [INFO] [main] [ ignoreDdl = false] [2025-09-16 16:29:35.682] [INFO] [main] [ enableMetricReportTask = false] [2025-09-16 16:29:35.682] [INFO] [main] [ sourceType = OB_MYSQL] [2025-09-16 16:29:35.682] [INFO] [main] [ columnCaseStrategy = follow-source] [2025-09-16 16:29:35.682] [INFO] [main] [ throttleMemoryBound = 1073741824] [2025-09-16 16:29:35.682] [INFO] [main] [ sinkType = OB_MYSQL] [2025-09-16 16:29:35.682] [INFO] [main] [ dispatcherClassName = com.oceanbase.oms.connector.dispatcher.scheduler.DefaultTransactionScheduler] [2025-09-16 16:29:35.682] [INFO] [main] [ listenPort = 16000] [2025-09-16 16:29:35.682] [INFO] [main] [ allowRecordTypes = DELETE,INSERT,UPDATE,DDL] [2025-09-16 16:29:35.682] [INFO] [main] [ ignoreCompensateDDL = false] [2025-09-16 16:29:35.682] [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] [2025-09-16 16:29:35.682] [INFO] [main] [[sink]] [2025-09-16 16:29:35.683] [INFO] [main] [ boosterClass = com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSinkBooster] [2025-09-16 16:29:35.683] [INFO] [main] [ timezone = +08:00] [2025-09-16 16:29:35.683] [INFO] [main] [ filterHiddenPK = false] [2025-09-16 16:29:35.683] [INFO] [main] [ isPreLoadAllTableSchema = false] [2025-09-16 16:29:35.683] [INFO] [main] [ type = JDBC_SINK_OB_MYSQL] [2025-09-16 16:29:35.683] [INFO] [main] [ ignoreDdl = false] [2025-09-16 16:29:35.683] [INFO] [main] [ ignoreConflictDetectOfNullValue = true] [2025-09-16 16:29:35.683] [INFO] [main] [ password = PreP123!@#] [2025-09-16 16:29:35.683] [INFO] [main] [ columnCaseStrategy = default] [2025-09-16 16:29:35.683] [INFO] [main] [ sinkMaps = [["jiuyang_business","sys_enterprise"],["jiuyang_business","sys_store"]]] [2025-09-16 16:29:35.683] [INFO] [main] [ jar = jdbc-sink-ob-mysql.jar] [2025-09-16 16:29:35.683] [INFO] [main] [ enableTransactionWriter = true] [2025-09-16 16:29:35.683] [INFO] [main] [ supportedTimezone = []] [2025-09-16 16:29:35.683] [INFO] [main] [ tenant = pre] [2025-09-16 16:29:35.683] [INFO] [main] [ enableNoUniqueConstraintTableReplicate = false] [2025-09-16 16:29:35.683] [INFO] [main] [ dbTableCaseStrategy = default] [2025-09-16 16:29:35.683] [INFO] [main] [ dbVersion = 4.3.1.0] [2025-09-16 16:29:35.683] [INFO] [main] [ endpointId = e_72z412weyzsw] [2025-09-16 16:29:35.683] [INFO] [main] [ sourceIsStore = true] [2025-09-16 16:29:35.683] [INFO] [main] [ insertMode = INSERT] [2025-09-16 16:29:35.683] [INFO] [main] [ charsetReplaceMap = {}] [2025-09-16 16:29:35.683] [INFO] [main] [ sourceType = OB_MYSQL] [2025-09-16 16:29:35.683] [INFO] [main] [ jdbcUrl = jdbc:mysql://199.16.3.52:2883?useUnicode=true&allowMultiQueries=true&socketTimeout=50000&characterEncoding=utf8&readOnlyPropagatesToServer=false] [2025-09-16 16:29:35.683] [INFO] [main] [ ignoreRedunantColumnsReplicate = false] [2025-09-16 16:29:35.683] [INFO] [main] [ workerNum = 4] [2025-09-16 16:29:35.683] [INFO] [main] [ sinkType = OB_MYSQL] [2025-09-16 16:29:35.683] [INFO] [main] [ username = root@pre] [2025-09-16 16:29:35.683] [INFO] [main] [[source]] [2025-09-16 16:29:35.683] [INFO] [main] [ checkpoint = {"OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0":"1758009535"}] [2025-09-16 16:29:35.683] [INFO] [main] [ boosterClass = com.oceanbase.oms.connector.source.store.MultiStoreSourceBooster] [2025-09-16 16:29:35.683] [INFO] [main] [ taskIdentity = np_72zt6yn658v4] [2025-09-16 16:29:35.683] [INFO] [main] [ enableOmsConnectorV2Report = true] [2025-09-16 16:29:35.683] [INFO] [main] [ clients = [{"clientId":"OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0","clusterManagerUrl":"http://199.16.3.15:8088","subtopic":"OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0"}]] [2025-09-16 16:29:35.683] [INFO] [main] [ enableNoUniqueConstraintTableReplicate = false] [2025-09-16 16:29:35.683] [INFO] [main] [ dbVersion = 4.3.1.0] [2025-09-16 16:29:35.683] [INFO] [main] [ timezone = +08:00] [2025-09-16 16:29:35.683] [INFO] [main] [ dbType = OB_MYSQL] [2025-09-16 16:29:35.683] [INFO] [main] [ taskSubId = 1] [2025-09-16 16:29:35.684] [INFO] [main] [ type = STORE_SOURCE] [2025-09-16 16:29:35.684] [INFO] [main] [ sourceBatchMemorySize = 16777216] [2025-09-16 16:29:35.684] [INFO] [main] [ ignoreDdl = false] [2025-09-16 16:29:35.684] [INFO] [main] [ password = RM_oms] [2025-09-16 16:29:35.684] [INFO] [main] [ taskType = migrate] [2025-09-16 16:29:35.684] [INFO] [main] [ jar = connector-source-store.jar] [2025-09-16 16:29:35.684] [INFO] [main] [ workerNum = 4] [2025-09-16 16:29:35.684] [INFO] [main] [ username = RM_oms] [2025-09-16 16:29:35.684] [INFO] [main] [ splitThreshold = 64] [2025-09-16 16:29:35.689] [INFO] [main] [BootStrap: init memoryBoound value to 1073741824] [2025-09-16 16:29:35.694] [INFO] [main] [BootStrapPanel: register keep alive url [/status]] [2025-09-16 16:29:35.695] [INFO] [main] [BootStrapPanel: register source stats url [/source/stats]] [2025-09-16 16:29:35.695] [INFO] [main] [BootStrapPanel: register checkpoint query url [/checkpoint/query]] [2025-09-16 16:29:35.696] [INFO] [main] [BootStrapPanel: register throttle control url [/throttle/control]] [2025-09-16 16:29:35.697] [INFO] [main] [BootStrapPanel: register throttle query url [/throttle/query]] [2025-09-16 16:29:35.713] [INFO] [main] [Writer init with arguments, write mode[SEMI_BATCH_PREPARE_STATEMENT], maxTxnRetryTimes[1000], retryIntervalTime[1000],dryRun[false], printSql[false], slowSqlThreshold[15], ignoreDDL[false], hotKeyMerge[false]typeStatistics[false], fullBatchWithSameTable[false], canLobBatched[true]] [2025-09-16 16:29:35.715] [INFO] [main] [Writer init with arguments, write mode[SEMI_BATCH_PREPARE_STATEMENT], maxTxnRetryTimes[1000], retryIntervalTime[1000],dryRun[false], printSql[false], slowSqlThreshold[15], ignoreDDL[false], hotKeyMerge[false]typeStatistics[false], fullBatchWithSameTable[false], canLobBatched[true]] [2025-09-16 16:29:35.715] [INFO] [main] [Writer init with arguments, write mode[SEMI_BATCH_PREPARE_STATEMENT], maxTxnRetryTimes[1000], retryIntervalTime[1000],dryRun[false], printSql[false], slowSqlThreshold[15], ignoreDDL[false], hotKeyMerge[false]typeStatistics[false], fullBatchWithSameTable[false], canLobBatched[true]] [2025-09-16 16:29:35.715] [INFO] [main] [Writer init with arguments, write mode[SEMI_BATCH_PREPARE_STATEMENT], maxTxnRetryTimes[1000], retryIntervalTime[1000],dryRun[false], printSql[false], slowSqlThreshold[15], ignoreDDL[false], hotKeyMerge[false]typeStatistics[false], fullBatchWithSameTable[false], canLobBatched[true]] [2025-09-16 16:29:35.724] [INFO] [main] [storeSource config: {checkpoint={"OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0":"1758009535"}, useDRCNet=true, cmUrl=http://199.16.3.15:8088, storePassword=RM_oms, boosterClass=com.oceanbase.oms.connector.source.store.MultiStoreSourceBooster, enableOmsConnectorV2Report=true, clients=[{"clientId":"OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0","clusterManagerUrl":"http://199.16.3.15:8088","subtopic":"OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0"}], timezone=+08:00, storeEnableTransactionSeq=false, type=STORE_SOURCE, sourceBatchMemorySize=16777216, ignoreDdl=false, password=RM_oms, taskType=migrate, storeTimeoutSec=120, jar=connector-source-store.jar, timestamp=1758009535, taskIdentity=np_72zt6yn658v4, srcSubTopic=OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0, enableNoUniqueConstraintTableReplicate=false, clientId=OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0, dbVersion=4.3.1.0, dbType=OB_MYSQL, taskSubId=1, storeRetryTimes=1000, storeUsername=RM_oms, askSelfUnit=false, storeBlackFilterStr=pre.jiuyang_system.drc_txn*|pre.jiuyang_system.delay_delete_*, workerNum=4, storeWhiteFilterStr=pre.jiuyang_system.sys_store|pre.jiuyang_system.sys_enterprise, username=RM_oms, splitThreshold=64}] [2025-09-16 16:29:35.726] [INFO] [main] [start transaction assembler] [2025-09-16 16:29:35.726] [WARN] [main] [StoreSource: cache enabled[false]] [2025-09-16 16:29:35.730] [INFO] [main] [useCheckpointListener: true] [2025-09-16 16:29:35.746] [INFO] [main] [useSchemaCache: false, useBetaListener: false] [2025-09-16 16:29:35.747] [INFO] [main] [create drc client with config: {client.connectionTimeout=120, binlogPassword=RM_oms, subTopic=OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0, client.socketTimeout=120, askSelfUnit=false, manager.host=http://199.16.3.15:8088, client.requireCompleteTxn=false, timestamp=1758009535, binlogUsername=RM_oms, useDrcNet=true, server.messageType=binary, server.maxRetriedTimes=1000}] [2025-09-16 16:29:35.753] [INFO] [main] [Initialize the service with starting point: 1758009535] [2025-09-16 16:29:35.754] [INFO] [main] [drc client started] [2025-09-16 16:29:35.754] [INFO] [main] [store source crawler info is {crawler=null, drcConfig={subTopic=OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0, client.requireCompleteTxn=false, binlogPassword=RM_oms, server.messageType=binary, binlogUsername=RM_oms, client.connectionTimeout=120, version=2.0.0, askSelfUnit=false, useDrcNet=true, client.socketTimeout=120, server.maxRetriedTimes=1000, checkpoint.period=500, manager.host=http://199.16.3.15:8088, timestamp=1758009535}, store=null}] [2025-09-16 16:29:35.756] [INFO] [main] [start drc client] [2025-09-16 16:29:36.048] [ERROR] [main] [notifyStopped:] java.lang.RuntimeException: com.oceanbase.oms.store.client.HttpBadResponseException: CmBaseException(oldErrorCode=0, errMsg=Found no active stores under topic [OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0], reason=null, relativeDocs=null) at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:93) at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:31) at com.oceanbase.connector.framework.threadmanager.TaskManager.start(TaskManager.java:49) at com.oceanbase.oms.connector.coordinator.BootStrapPanel.boot(BootStrapPanel.java:240) at com.oceanbase.oms.connector.jdbc.coordinator.Bootstrap.main(Bootstrap.java:44) Caused by: com.oceanbase.oms.store.client.HttpBadResponseException: CmBaseException(oldErrorCode=0, errMsg=Found no active stores under topic [OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0], reason=null, relativeDocs=null) at com.oceanbase.oms.store.client.impl.ServerProxy.askStore(ServerProxy.java:487) at com.oceanbase.oms.store.client.impl.ClusterManagers.findStore(ClusterManagers.java:101) at com.oceanbase.oms.store.client.impl.DRCClientImpl.connectClusterManager(DRCClientImpl.java:380) at com.oceanbase.oms.store.client.impl.DRCClientImpl.startService(DRCClientImpl.java:677) at com.oceanbase.oms.connector.source.store.StoreSource.start(StoreSource.java:159) at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:86) ... 4 common frames omitted [2025-09-16 16:29:36.051] [INFO] [main] [close sourceTaskManager done] [2025-09-16 16:29:36.051] [INFO] [main] [close sourceBooster done] [2025-09-16 16:29:36.053] [INFO] [forward_slot0-(ETLProcessor)-queue_slot1] [SerialBridgeTask [forward_slot0-(ETLProcessor)-queue_slot1] stopped] [2025-09-16 16:29:36.058] [INFO] [queue_slot1-()-TransactionScheduler] [SerialBridgeTask [queue_slot1-()-TransactionScheduler] stopped] [2025-09-16 16:29:36.059] [INFO] [main] [close bridgeTaskManager done] [2025-09-16 16:29:36.063] [INFO] [sinkTask-0] [SyncSinkTask [sinkTask-0] stopped] [2025-09-16 16:29:36.064] [INFO] [sinkTask-0] [{dataSource-1} closing ...] [2025-09-16 16:29:36.068] [INFO] [sinkTask-0] [{dataSource-1} closed] [2025-09-16 16:29:36.068] [INFO] [sinkTask-0] [{dataSource-0} closing ...] [2025-09-16 16:29:36.068] [INFO] [main] [{dataSource-0} closing ...] [2025-09-16 16:29:36.072] [INFO] [sinkTask-1] [SyncSinkTask [sinkTask-1] stopped] [2025-09-16 16:29:36.073] [INFO] [sinkTask-1] [{dataSource-0} closing ...] [2025-09-16 16:29:36.073] [INFO] [main] [{dataSource-0} closing ...] [2025-09-16 16:29:36.074] [INFO] [sinkTask-2] [SyncSinkTask [sinkTask-2] stopped] [2025-09-16 16:29:36.074] [INFO] [sinkTask-2] [{dataSource-0} closing ...] [2025-09-16 16:29:36.074] [INFO] [main] [{dataSource-0} closing ...] [2025-09-16 16:29:36.075] [INFO] [sinkTask-3] [SyncSinkTask [sinkTask-3] stopped] [2025-09-16 16:29:36.075] [INFO] [sinkTask-3] [{dataSource-0} closing ...] [2025-09-16 16:29:36.076] [INFO] [main] [{dataSource-0} closing ...] [2025-09-16 16:29:36.076] [INFO] [main] [close sinkTaskManager done] [2025-09-16 16:29:36.077] [INFO] [main] [close sinkBooster done] [2025-09-16 16:29:36.077] [INFO] [main] [close frameworkCustomize done] [2025-09-16 16:29:36.077] [INFO] [main] [close reporter done] [2025-09-16 16:29:36.078] [INFO] [main] [close httpServer done] [2025-09-16 16:29:36.078] [INFO] [main] [close timerTaskScheduler done] [2025-09-16 16:29:36.078] [WARN] [main] [FrameWork exist {}] java.lang.RuntimeException: com.oceanbase.oms.store.client.HttpBadResponseException: CmBaseException(oldErrorCode=0, errMsg=Found no active stores under topic [OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0], reason=null, relativeDocs=null) at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:93) at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:31) at com.oceanbase.connector.framework.threadmanager.TaskManager.start(TaskManager.java:49) at com.oceanbase.oms.connector.coordinator.BootStrapPanel.boot(BootStrapPanel.java:240) at com.oceanbase.oms.connector.jdbc.coordinator.Bootstrap.main(Bootstrap.java:44) Caused by: com.oceanbase.oms.store.client.HttpBadResponseException: CmBaseException(oldErrorCode=0, errMsg=Found no active stores under topic [OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0], reason=null, relativeDocs=null) at com.oceanbase.oms.store.client.impl.ServerProxy.askStore(ServerProxy.java:487) at com.oceanbase.oms.store.client.impl.ClusterManagers.findStore(ClusterManagers.java:101) at com.oceanbase.oms.store.client.impl.DRCClientImpl.connectClusterManager(DRCClientImpl.java:380) at com.oceanbase.oms.store.client.impl.DRCClientImpl.startService(DRCClientImpl.java:677) at com.oceanbase.oms.connector.source.store.StoreSource.start(StoreSource.java:159) at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:86) ... 4 common frames omitted [2025-09-16 16:29:36.087] [ERROR] [main] [main thread error] java.lang.RuntimeException: com.oceanbase.oms.store.client.HttpBadResponseException: CmBaseException(oldErrorCode=0, errMsg=Found no active stores under topic [OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0], reason=null, relativeDocs=null) at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:93) at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:31) at com.oceanbase.connector.framework.threadmanager.TaskManager.start(TaskManager.java:49) at com.oceanbase.oms.connector.coordinator.BootStrapPanel.boot(BootStrapPanel.java:240) at com.oceanbase.oms.connector.jdbc.coordinator.Bootstrap.main(Bootstrap.java:44) Caused by: com.oceanbase.oms.store.client.HttpBadResponseException: CmBaseException(oldErrorCode=0, errMsg=Found no active stores under topic [OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0], reason=null, relativeDocs=null) at com.oceanbase.oms.store.client.impl.ServerProxy.askStore(ServerProxy.java:487) at com.oceanbase.oms.store.client.impl.ClusterManagers.findStore(ClusterManagers.java:101) at com.oceanbase.oms.store.client.impl.DRCClientImpl.connectClusterManager(DRCClientImpl.java:380) at com.oceanbase.oms.store.client.impl.DRCClientImpl.startService(DRCClientImpl.java:677) at com.oceanbase.oms.connector.source.store.StoreSource.start(StoreSource.java:159) at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:86) ... 4 common frames omitted [2025-09-16 16:55:25.777] [INFO] [main] [NativeFSLock: acquire with pid [22345]] [2025-09-16 16:55:25.782] [INFO] [main] [error file not exists] [2025-09-16 16:55:25.798] [INFO] [main] [system default timezone : GMT+08:00] [2025-09-16 16:55:25.963] [INFO] [main] [build condition cache, caseInsensitive: true, condition : { "DefaultConnectorCondition" : { "blackCondition" : "[{\"all\":false,\"sub\":[{\"func\":\"fn\",\"name\":\"drc_txn*\"},{\"func\":\"fn\",\"name\":\"DRC_TXN*\"},{\"func\":\"fn\",\"name\":\"delay_delete_*\"},{\"func\":\"fn\",\"name\":\"DELAY_DELETE_*\"}],\"func\":\"fn\",\"name\":\"pre.jiuyang_system\",\"map\":\"jiuyang_business\"}]", "whiteCondition" : "[{\"all\":false,\"sub\":[{\"name\":\"sys_store\",\"map\":\"sys_store\"},{\"name\":\"sys_enterprise\",\"map\":\"sys_enterprise\"}],\"name\":\"pre.jiuyang_system\",\"map\":\"jiuyang_business\"}]" } }] [2025-09-16 16:55:25.999] [INFO] [main] [map source class [com.oceanbase.oms.connector.source.store.MultiStoreSourceBooster] to [com.oceanbase.oms.connector.source.store.MultiStoreSourceBooster]] [2025-09-16 16:55:26.001] [INFO] [main] [map sink class [com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSinkBooster] to [com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSinkBooster]] [2025-09-16 16:55:26.012] [WARN] [main] [MySQL not determinate utf8mb4 support or not] [2025-09-16 16:55:26.012] [WARN] [main] [MySQL not determinate utf8mb4 support or not] [2025-09-16 16:55:26.047] [INFO] [main] [auto set coordinator config: {bridgeQueueSize=64, throttleMemoryBound=1073741824} by metrics MID] [2025-09-16 16:55:26.052] [INFO] [main] [auto set source config: {sourceBatchMemorySize=16777216, splitThreshold=64} by metrics MID] [2025-09-16 16:55:26.072] [INFO] [main] [CastConfig: com.oceanbase.oms.connector.common.cast.CastConfig@477b4cdf] [2025-09-16 16:55:26.088] [INFO] [main] [OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0-null-null is not valid] [2025-09-16 16:55:26.088] [INFO] [main] [[condition]] [2025-09-16 16:55:26.088] [INFO] [main] [ blackCondition = [{"all":false,"sub":[{"func":"fn","name":"drc_txn*"},{"func":"fn","name":"DRC_TXN*"},{"func":"fn","name":"delay_delete_*"},{"func":"fn","name":"DELAY_DELETE_*"}],"func":"fn","name":"pre.jiuyang_system","map":"jiuyang_business"}]] [2025-09-16 16:55:26.089] [INFO] [main] [ whiteCondition = [{"all":false,"sub":[{"name":"sys_store","map":"sys_store"},{"name":"sys_enterprise","map":"sys_enterprise"}],"name":"pre.jiuyang_system","map":"jiuyang_business"}]] [2025-09-16 16:55:26.089] [INFO] [main] [[coordinator]] [2025-09-16 16:55:26.089] [INFO] [main] [ taskIdentity = np_72zt6yn658v4] [2025-09-16 16:55:26.089] [INFO] [main] [ enableOmsConnectorV2Report = true] [2025-09-16 16:55:26.089] [INFO] [main] [ isCaseSensitive = false] [2025-09-16 16:55:26.089] [INFO] [main] [ dbTableCaseStrategy = follow-source] [2025-09-16 16:55:26.089] [INFO] [main] [ streamMode = true] [2025-09-16 16:55:26.089] [INFO] [main] [ timezone = +08:00] [2025-09-16 16:55:26.089] [INFO] [main] [ enableActiveReportTask = false] [2025-09-16 16:55:26.089] [INFO] [main] [ bridgeQueueSize = 64] [2025-09-16 16:55:26.089] [INFO] [main] [ ignoreDdl = false] [2025-09-16 16:55:26.089] [INFO] [main] [ enableMetricReportTask = false] [2025-09-16 16:55:26.089] [INFO] [main] [ sourceType = OB_MYSQL] [2025-09-16 16:55:26.089] [INFO] [main] [ columnCaseStrategy = follow-source] [2025-09-16 16:55:26.089] [INFO] [main] [ throttleMemoryBound = 1073741824] [2025-09-16 16:55:26.089] [INFO] [main] [ sinkType = OB_MYSQL] [2025-09-16 16:55:26.090] [INFO] [main] [ listenPort = 16000] [2025-09-16 16:55:26.090] [INFO] [main] [ allowRecordTypes = DELETE,INSERT,UPDATE,DDL] [2025-09-16 16:55:26.090] [INFO] [main] [ ignoreCompensateDDL = false] [2025-09-16 16:55:26.090] [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] [2025-09-16 16:55:26.090] [INFO] [main] [[sink]] [2025-09-16 16:55:26.090] [INFO] [main] [ boosterClass = com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSinkBooster] [2025-09-16 16:55:26.090] [INFO] [main] [ timezone = +08:00] [2025-09-16 16:55:26.090] [INFO] [main] [ filterHiddenPK = false] [2025-09-16 16:55:26.090] [INFO] [main] [ isPreLoadAllTableSchema = false] [2025-09-16 16:55:26.090] [INFO] [main] [ type = JDBC_SINK_OB_MYSQL] [2025-09-16 16:55:26.090] [INFO] [main] [ ignoreDdl = false] [2025-09-16 16:55:26.090] [INFO] [main] [ ignoreConflictDetectOfNullValue = true] [2025-09-16 16:55:26.090] [INFO] [main] [ password = PreP123!@#] [2025-09-16 16:55:26.090] [INFO] [main] [ columnCaseStrategy = follow-source] [2025-09-16 16:55:26.090] [INFO] [main] [ sinkMaps = [["jiuyang_business","sys_enterprise"],["jiuyang_business","sys_store"]]] [2025-09-16 16:55:26.090] [INFO] [main] [ jar = jdbc-sink-ob-mysql.jar] [2025-09-16 16:55:26.090] [INFO] [main] [ tenant = pre] [2025-09-16 16:55:26.091] [INFO] [main] [ enableNoUniqueConstraintTableReplicate = false] [2025-09-16 16:55:26.091] [INFO] [main] [ dbTableCaseStrategy = follow-source] [2025-09-16 16:55:26.091] [INFO] [main] [ dbVersion = 4.3.1.0] [2025-09-16 16:55:26.091] [INFO] [main] [ endpointId = e_72z412weyzsw] [2025-09-16 16:55:26.091] [INFO] [main] [ sourceIsStore = true] [2025-09-16 16:55:26.091] [INFO] [main] [ insertMode = INSERT] [2025-09-16 16:55:26.091] [INFO] [main] [ charsetReplaceMap = {}] [2025-09-16 16:55:26.091] [INFO] [main] [ sourceType = OB_MYSQL] [2025-09-16 16:55:26.091] [INFO] [main] [ jdbcUrl = jdbc:mysql://199.16.3.52:2883?useUnicode=true&allowMultiQueries=true&socketTimeout=50000&characterEncoding=utf8&readOnlyPropagatesToServer=false] [2025-09-16 16:55:26.091] [INFO] [main] [ ignoreRedunantColumnsReplicate = false] [2025-09-16 16:55:26.091] [INFO] [main] [ workerNum = 4] [2025-09-16 16:55:26.091] [INFO] [main] [ sinkType = OB_MYSQL] [2025-09-16 16:55:26.091] [INFO] [main] [ username = root@pre] [2025-09-16 16:55:26.091] [INFO] [main] [[source]] [2025-09-16 16:55:26.092] [INFO] [main] [ checkpoint = {"OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0":"1758009535"}] [2025-09-16 16:55:26.092] [INFO] [main] [ boosterClass = com.oceanbase.oms.connector.source.store.MultiStoreSourceBooster] [2025-09-16 16:55:26.092] [INFO] [main] [ taskIdentity = np_72zt6yn658v4] [2025-09-16 16:55:26.092] [INFO] [main] [ enableOmsConnectorV2Report = true] [2025-09-16 16:55:26.092] [INFO] [main] [ clients = [{"clientId":"OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0","clusterManagerUrl":"http://199.16.3.15:8088","subtopic":"OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0"}]] [2025-09-16 16:55:26.092] [INFO] [main] [ enableNoUniqueConstraintTableReplicate = false] [2025-09-16 16:55:26.092] [INFO] [main] [ dbVersion = 4.3.1.0] [2025-09-16 16:55:26.092] [INFO] [main] [ timezone = +08:00] [2025-09-16 16:55:26.092] [INFO] [main] [ dbType = OB_MYSQL] [2025-09-16 16:55:26.092] [INFO] [main] [ taskSubId = 1] [2025-09-16 16:55:26.092] [INFO] [main] [ type = STORE_SOURCE] [2025-09-16 16:55:26.092] [INFO] [main] [ sourceBatchMemorySize = 16777216] [2025-09-16 16:55:26.092] [INFO] [main] [ ignoreDdl = false] [2025-09-16 16:55:26.092] [INFO] [main] [ password = RM_oms] [2025-09-16 16:55:26.092] [INFO] [main] [ taskType = migrate] [2025-09-16 16:55:26.092] [INFO] [main] [ jar = connector-source-store.jar] [2025-09-16 16:55:26.092] [INFO] [main] [ workerNum = 4] [2025-09-16 16:55:26.092] [INFO] [main] [ username = RM_oms] [2025-09-16 16:55:26.092] [INFO] [main] [ splitThreshold = 64] [2025-09-16 16:55:26.141] [INFO] [main] [store config: { "checkpoint" : "{\"OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0\":\"1758009535\"}", "boosterClass" : "com.oceanbase.oms.connector.source.store.MultiStoreSourceBooster", "taskIdentity" : "np_72zt6yn658v4", "enableOmsConnectorV2Report" : "true", "clients" : "[{\"clientId\":\"OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0\",\"clusterManagerUrl\":\"http://199.16.3.15:8088\",\"subtopic\":\"OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0\"}]", "enableNoUniqueConstraintTableReplicate" : "false", "dbVersion" : "4.3.1.0", "timezone" : "+08:00", "dbType" : "OB_MYSQL", "taskSubId" : "1", "type" : "STORE_SOURCE", "sourceBatchMemorySize" : "16777216", "connectionTimeoutSec" : "120", "ignoreDdl" : "false", "askSelfUnit" : "false", "password" : "RM_oms", "taskType" : "migrate", "maxRetries" : "1000", "transactionEnabled" : "false", "jar" : "connector-source-store.jar", "workerNum" : "4", "username" : "RM_oms", "splitThreshold" : "64" }] [2025-09-16 16:55:26.591] [INFO] [main] [[Init DruidDataSource]sessionParameters: {}] [2025-09-16 16:55:26.591] [INFO] [main] [199.16.3.52:2883 root@pre init sql:set foreign_key_checks = off] [2025-09-16 16:55:26.592] [INFO] [main] [init druid dataSource with loginTimeout[300], maxWaitMillis[12000], maxActive[4], initActive[4], minIdle[4]] [2025-09-16 16:55:26.592] [INFO] [main] [connect with url [jdbc:mysql://199.16.3.52:2883?readOnlyPropagatesToServer=false&useUnicode=true&rewriteBatchedStatements=true&socketTimeout=50000&connectTimeout=30000&allowMultiQueries=true&characterEncoding=utf8&netTimeoutForStreamingResults=28800&useSSL=false]] [2025-09-16 16:55:26.592] [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 199.16.3.52:2883 user root@pre characterSet ] [2025-09-16 16:55:26.608] [INFO] [main] [[Init DruidDataSource]sessionParameters: {}] [2025-09-16 16:55:26.608] [INFO] [main] [199.16.3.52:2883 root@pre init sql:set foreign_key_checks = off] [2025-09-16 16:55:26.608] [INFO] [main] [init druid dataSource with loginTimeout[300], maxWaitMillis[12000], maxActive[3], initActive[0], minIdle[0]] [2025-09-16 16:55:26.609] [INFO] [main] [connect with url [jdbc:mysql://199.16.3.52:2883?readOnlyPropagatesToServer=false&useUnicode=true&rewriteBatchedStatements=true&socketTimeout=172800000&connectTimeout=30000&allowMultiQueries=true&characterEncoding=utf8&netTimeoutForStreamingResults=28800&useSSL=false]] [2025-09-16 16:55:26.609] [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 199.16.3.52:2883 user root@pre characterSet ] [2025-09-16 16:55:26.818] [INFO] [main] [{dataSource-1} inited] [2025-09-16 16:55:27.028] [INFO] [main] [SHOW VARIABLES LIKE 'version_comment'] [2025-09-16 16:55:27.036] [INFO] [main] [sink db version:4.3.1.0] [2025-09-16 16:55:27.156] [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] [2025-09-16 16:55:27.165] [INFO] [main] [put coordinator.maxRecordCapacity: batchSize(64), workerNum(4), maxRecordCapacity: 16384, may have been set, so it's inconsistent with cal value ] [2025-09-16 16:55:27.238] [INFO] [main] [MatchDDLConfig: ] [2025-09-16 16:55:27.284] [INFO] [main] [ConcurrentArrayQueue mod MULTI_PRODUCER_MULTI_CONSUMER, size: 64] [2025-09-16 16:55:27.288] [INFO] [main] [ConcurrentArrayQueue mod MULTI_PRODUCER_MULTI_CONSUMER, size: 64] [2025-09-16 16:55:27.299] [INFO] [main] [[condition]] [2025-09-16 16:55:27.299] [INFO] [main] [ blackCondition = [{"all":false,"sub":[{"func":"fn","name":"drc_txn*"},{"func":"fn","name":"DRC_TXN*"},{"func":"fn","name":"delay_delete_*"},{"func":"fn","name":"DELAY_DELETE_*"}],"func":"fn","name":"pre.jiuyang_system","map":"jiuyang_business"}]] [2025-09-16 16:55:27.299] [INFO] [main] [ whiteCondition = [{"all":false,"sub":[{"name":"sys_store","map":"sys_store"},{"name":"sys_enterprise","map":"sys_enterprise"}],"name":"pre.jiuyang_system","map":"jiuyang_business"}]] [2025-09-16 16:55:27.299] [INFO] [main] [[coordinator]] [2025-09-16 16:55:27.299] [INFO] [main] [ taskIdentity = np_72zt6yn658v4] [2025-09-16 16:55:27.299] [INFO] [main] [ enableOmsConnectorV2Report = true] [2025-09-16 16:55:27.299] [INFO] [main] [ isCaseSensitive = false] [2025-09-16 16:55:27.299] [INFO] [main] [ dbTableCaseStrategy = follow-source] [2025-09-16 16:55:27.299] [INFO] [main] [ streamMode = true] [2025-09-16 16:55:27.299] [INFO] [main] [ maxRecordCapacity = 16384] [2025-09-16 16:55:27.299] [INFO] [main] [ timezone = +08:00] [2025-09-16 16:55:27.299] [INFO] [main] [ enableActiveReportTask = false] [2025-09-16 16:55:27.299] [INFO] [main] [ bridgeQueueSize = 64] [2025-09-16 16:55:27.299] [INFO] [main] [ ignoreDdl = false] [2025-09-16 16:55:27.299] [INFO] [main] [ enableMetricReportTask = false] [2025-09-16 16:55:27.299] [INFO] [main] [ sourceType = OB_MYSQL] [2025-09-16 16:55:27.299] [INFO] [main] [ columnCaseStrategy = follow-source] [2025-09-16 16:55:27.300] [INFO] [main] [ throttleMemoryBound = 1073741824] [2025-09-16 16:55:27.300] [INFO] [main] [ sinkType = OB_MYSQL] [2025-09-16 16:55:27.300] [INFO] [main] [ dispatcherClassName = com.oceanbase.oms.connector.dispatcher.scheduler.DefaultTransactionScheduler] [2025-09-16 16:55:27.300] [INFO] [main] [ listenPort = 16000] [2025-09-16 16:55:27.300] [INFO] [main] [ allowRecordTypes = DELETE,INSERT,UPDATE,DDL] [2025-09-16 16:55:27.300] [INFO] [main] [ ignoreCompensateDDL = false] [2025-09-16 16:55:27.300] [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] [2025-09-16 16:55:27.300] [INFO] [main] [[sink]] [2025-09-16 16:55:27.300] [INFO] [main] [ boosterClass = com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSinkBooster] [2025-09-16 16:55:27.300] [INFO] [main] [ timezone = +08:00] [2025-09-16 16:55:27.300] [INFO] [main] [ filterHiddenPK = false] [2025-09-16 16:55:27.300] [INFO] [main] [ isPreLoadAllTableSchema = false] [2025-09-16 16:55:27.300] [INFO] [main] [ type = JDBC_SINK_OB_MYSQL] [2025-09-16 16:55:27.300] [INFO] [main] [ ignoreDdl = false] [2025-09-16 16:55:27.300] [INFO] [main] [ ignoreConflictDetectOfNullValue = true] [2025-09-16 16:55:27.300] [INFO] [main] [ password = PreP123!@#] [2025-09-16 16:55:27.300] [INFO] [main] [ columnCaseStrategy = default] [2025-09-16 16:55:27.300] [INFO] [main] [ sinkMaps = [["jiuyang_business","sys_enterprise"],["jiuyang_business","sys_store"]]] [2025-09-16 16:55:27.300] [INFO] [main] [ jar = jdbc-sink-ob-mysql.jar] [2025-09-16 16:55:27.300] [INFO] [main] [ enableTransactionWriter = true] [2025-09-16 16:55:27.300] [INFO] [main] [ supportedTimezone = []] [2025-09-16 16:55:27.300] [INFO] [main] [ tenant = pre] [2025-09-16 16:55:27.300] [INFO] [main] [ enableNoUniqueConstraintTableReplicate = false] [2025-09-16 16:55:27.300] [INFO] [main] [ dbTableCaseStrategy = default] [2025-09-16 16:55:27.300] [INFO] [main] [ dbVersion = 4.3.1.0] [2025-09-16 16:55:27.300] [INFO] [main] [ endpointId = e_72z412weyzsw] [2025-09-16 16:55:27.300] [INFO] [main] [ sourceIsStore = true] [2025-09-16 16:55:27.300] [INFO] [main] [ insertMode = INSERT] [2025-09-16 16:55:27.300] [INFO] [main] [ charsetReplaceMap = {}] [2025-09-16 16:55:27.300] [INFO] [main] [ sourceType = OB_MYSQL] [2025-09-16 16:55:27.300] [INFO] [main] [ jdbcUrl = jdbc:mysql://199.16.3.52:2883?useUnicode=true&allowMultiQueries=true&socketTimeout=50000&characterEncoding=utf8&readOnlyPropagatesToServer=false] [2025-09-16 16:55:27.300] [INFO] [main] [ ignoreRedunantColumnsReplicate = false] [2025-09-16 16:55:27.300] [INFO] [main] [ workerNum = 4] [2025-09-16 16:55:27.300] [INFO] [main] [ sinkType = OB_MYSQL] [2025-09-16 16:55:27.300] [INFO] [main] [ username = root@pre] [2025-09-16 16:55:27.300] [INFO] [main] [[source]] [2025-09-16 16:55:27.300] [INFO] [main] [ checkpoint = {"OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0":"1758009535"}] [2025-09-16 16:55:27.301] [INFO] [main] [ boosterClass = com.oceanbase.oms.connector.source.store.MultiStoreSourceBooster] [2025-09-16 16:55:27.301] [INFO] [main] [ taskIdentity = np_72zt6yn658v4] [2025-09-16 16:55:27.301] [INFO] [main] [ enableOmsConnectorV2Report = true] [2025-09-16 16:55:27.301] [INFO] [main] [ clients = [{"clientId":"OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0","clusterManagerUrl":"http://199.16.3.15:8088","subtopic":"OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0"}]] [2025-09-16 16:55:27.301] [INFO] [main] [ enableNoUniqueConstraintTableReplicate = false] [2025-09-16 16:55:27.301] [INFO] [main] [ dbVersion = 4.3.1.0] [2025-09-16 16:55:27.301] [INFO] [main] [ timezone = +08:00] [2025-09-16 16:55:27.301] [INFO] [main] [ dbType = OB_MYSQL] [2025-09-16 16:55:27.301] [INFO] [main] [ taskSubId = 1] [2025-09-16 16:55:27.301] [INFO] [main] [ type = STORE_SOURCE] [2025-09-16 16:55:27.301] [INFO] [main] [ sourceBatchMemorySize = 16777216] [2025-09-16 16:55:27.301] [INFO] [main] [ ignoreDdl = false] [2025-09-16 16:55:27.301] [INFO] [main] [ password = RM_oms] [2025-09-16 16:55:27.301] [INFO] [main] [ taskType = migrate] [2025-09-16 16:55:27.301] [INFO] [main] [ jar = connector-source-store.jar] [2025-09-16 16:55:27.301] [INFO] [main] [ workerNum = 4] [2025-09-16 16:55:27.301] [INFO] [main] [ username = RM_oms] [2025-09-16 16:55:27.301] [INFO] [main] [ splitThreshold = 64] [2025-09-16 16:55:27.305] [INFO] [main] [BootStrap: init memoryBoound value to 1073741824] [2025-09-16 16:55:27.310] [INFO] [main] [BootStrapPanel: register keep alive url [/status]] [2025-09-16 16:55:27.311] [INFO] [main] [BootStrapPanel: register source stats url [/source/stats]] [2025-09-16 16:55:27.312] [INFO] [main] [BootStrapPanel: register checkpoint query url [/checkpoint/query]] [2025-09-16 16:55:27.313] [INFO] [main] [BootStrapPanel: register throttle control url [/throttle/control]] [2025-09-16 16:55:27.314] [INFO] [main] [BootStrapPanel: register throttle query url [/throttle/query]] [2025-09-16 16:55:27.331] [INFO] [main] [Writer init with arguments, write mode[SEMI_BATCH_PREPARE_STATEMENT], maxTxnRetryTimes[1000], retryIntervalTime[1000],dryRun[false], printSql[false], slowSqlThreshold[15], ignoreDDL[false], hotKeyMerge[false]typeStatistics[false], fullBatchWithSameTable[false], canLobBatched[true]] [2025-09-16 16:55:27.332] [INFO] [main] [Writer init with arguments, write mode[SEMI_BATCH_PREPARE_STATEMENT], maxTxnRetryTimes[1000], retryIntervalTime[1000],dryRun[false], printSql[false], slowSqlThreshold[15], ignoreDDL[false], hotKeyMerge[false]typeStatistics[false], fullBatchWithSameTable[false], canLobBatched[true]] [2025-09-16 16:55:27.332] [INFO] [main] [Writer init with arguments, write mode[SEMI_BATCH_PREPARE_STATEMENT], maxTxnRetryTimes[1000], retryIntervalTime[1000],dryRun[false], printSql[false], slowSqlThreshold[15], ignoreDDL[false], hotKeyMerge[false]typeStatistics[false], fullBatchWithSameTable[false], canLobBatched[true]] [2025-09-16 16:55:27.332] [INFO] [main] [Writer init with arguments, write mode[SEMI_BATCH_PREPARE_STATEMENT], maxTxnRetryTimes[1000], retryIntervalTime[1000],dryRun[false], printSql[false], slowSqlThreshold[15], ignoreDDL[false], hotKeyMerge[false]typeStatistics[false], fullBatchWithSameTable[false], canLobBatched[true]] [2025-09-16 16:55:27.340] [INFO] [main] [storeSource config: {checkpoint={"OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0":"1758009535"}, useDRCNet=true, cmUrl=http://199.16.3.15:8088, storePassword=RM_oms, boosterClass=com.oceanbase.oms.connector.source.store.MultiStoreSourceBooster, enableOmsConnectorV2Report=true, clients=[{"clientId":"OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0","clusterManagerUrl":"http://199.16.3.15:8088","subtopic":"OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0"}], timezone=+08:00, storeEnableTransactionSeq=false, type=STORE_SOURCE, sourceBatchMemorySize=16777216, ignoreDdl=false, password=RM_oms, taskType=migrate, storeTimeoutSec=120, jar=connector-source-store.jar, timestamp=1758009535, taskIdentity=np_72zt6yn658v4, srcSubTopic=OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0, enableNoUniqueConstraintTableReplicate=false, clientId=OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0, dbVersion=4.3.1.0, dbType=OB_MYSQL, taskSubId=1, storeRetryTimes=1000, storeUsername=RM_oms, askSelfUnit=false, storeBlackFilterStr=pre.jiuyang_system.drc_txn*|pre.jiuyang_system.delay_delete_*, workerNum=4, storeWhiteFilterStr=pre.jiuyang_system.sys_store|pre.jiuyang_system.sys_enterprise, username=RM_oms, splitThreshold=64}] [2025-09-16 16:55:27.341] [INFO] [main] [start transaction assembler] [2025-09-16 16:55:27.342] [WARN] [main] [StoreSource: cache enabled[false]] [2025-09-16 16:55:27.349] [INFO] [main] [useCheckpointListener: true] [2025-09-16 16:55:27.370] [INFO] [main] [useSchemaCache: false, useBetaListener: false] [2025-09-16 16:55:27.370] [INFO] [main] [create drc client with config: {client.connectionTimeout=120, binlogPassword=RM_oms, subTopic=OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0, client.socketTimeout=120, askSelfUnit=false, manager.host=http://199.16.3.15:8088, client.requireCompleteTxn=false, timestamp=1758009535, binlogUsername=RM_oms, useDrcNet=true, server.messageType=binary, server.maxRetriedTimes=1000}] [2025-09-16 16:55:27.376] [INFO] [main] [Initialize the service with starting point: 1758009535] [2025-09-16 16:55:27.377] [INFO] [main] [drc client started] [2025-09-16 16:55:27.377] [INFO] [main] [store source crawler info is {crawler=null, drcConfig={subTopic=OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0, client.requireCompleteTxn=false, binlogPassword=RM_oms, server.messageType=binary, binlogUsername=RM_oms, client.connectionTimeout=120, version=2.0.0, askSelfUnit=false, useDrcNet=true, client.socketTimeout=120, server.maxRetriedTimes=1000, checkpoint.period=500, manager.host=http://199.16.3.15:8088, timestamp=1758009535}, store=null}] [2025-09-16 16:55:27.379] [INFO] [main] [start drc client] [2025-09-16 16:55:29.365] [ERROR] [main] [notifyStopped:] java.lang.RuntimeException: com.oceanbase.oms.store.client.HttpBadResponseException: CmBaseException(oldErrorCode=0, errMsg=Found no active stores under topic [OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0], reason=null, relativeDocs=null) at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:93) at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:31) at com.oceanbase.connector.framework.threadmanager.TaskManager.start(TaskManager.java:49) at com.oceanbase.oms.connector.coordinator.BootStrapPanel.boot(BootStrapPanel.java:240) at com.oceanbase.oms.connector.jdbc.coordinator.Bootstrap.main(Bootstrap.java:44) Caused by: com.oceanbase.oms.store.client.HttpBadResponseException: CmBaseException(oldErrorCode=0, errMsg=Found no active stores under topic [OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0], reason=null, relativeDocs=null) at com.oceanbase.oms.store.client.impl.ServerProxy.askStore(ServerProxy.java:487) at com.oceanbase.oms.store.client.impl.ClusterManagers.findStore(ClusterManagers.java:101) at com.oceanbase.oms.store.client.impl.DRCClientImpl.connectClusterManager(DRCClientImpl.java:380) at com.oceanbase.oms.store.client.impl.DRCClientImpl.startService(DRCClientImpl.java:677) at com.oceanbase.oms.connector.source.store.StoreSource.start(StoreSource.java:159) at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:86) ... 4 common frames omitted [2025-09-16 16:55:29.367] [INFO] [main] [close sourceTaskManager done] [2025-09-16 16:55:29.367] [INFO] [main] [close sourceBooster done] [2025-09-16 16:55:29.371] [INFO] [forward_slot0-(ETLProcessor)-queue_slot1] [SerialBridgeTask [forward_slot0-(ETLProcessor)-queue_slot1] stopped] [2025-09-16 16:55:29.372] [INFO] [queue_slot1-()-TransactionScheduler] [SerialBridgeTask [queue_slot1-()-TransactionScheduler] stopped] [2025-09-16 16:55:29.372] [INFO] [main] [close bridgeTaskManager done] [2025-09-16 16:55:29.373] [INFO] [sinkTask-0] [SyncSinkTask [sinkTask-0] stopped] [2025-09-16 16:55:29.373] [INFO] [sinkTask-0] [{dataSource-1} closing ...] [2025-09-16 16:55:29.377] [INFO] [sinkTask-0] [{dataSource-1} closed] [2025-09-16 16:55:29.377] [INFO] [sinkTask-0] [{dataSource-0} closing ...] [2025-09-16 16:55:29.377] [INFO] [main] [{dataSource-0} closing ...] [2025-09-16 16:55:29.379] [INFO] [sinkTask-1] [SyncSinkTask [sinkTask-1] stopped] [2025-09-16 16:55:29.379] [INFO] [sinkTask-1] [{dataSource-0} closing ...] [2025-09-16 16:55:29.379] [INFO] [main] [{dataSource-0} closing ...] [2025-09-16 16:55:29.383] [INFO] [sinkTask-2] [SyncSinkTask [sinkTask-2] stopped] [2025-09-16 16:55:29.383] [INFO] [sinkTask-2] [{dataSource-0} closing ...] [2025-09-16 16:55:29.383] [INFO] [main] [{dataSource-0} closing ...] [2025-09-16 16:55:29.388] [INFO] [sinkTask-3] [SyncSinkTask [sinkTask-3] stopped] [2025-09-16 16:55:29.388] [INFO] [sinkTask-3] [{dataSource-0} closing ...] [2025-09-16 16:55:29.388] [INFO] [main] [{dataSource-0} closing ...] [2025-09-16 16:55:29.388] [INFO] [main] [close sinkTaskManager done] [2025-09-16 16:55:29.389] [INFO] [main] [close sinkBooster done] [2025-09-16 16:55:29.389] [INFO] [main] [close frameworkCustomize done] [2025-09-16 16:55:29.389] [INFO] [main] [close reporter done] [2025-09-16 16:55:29.390] [INFO] [main] [close httpServer done] [2025-09-16 16:55:29.390] [INFO] [main] [close timerTaskScheduler done] [2025-09-16 16:55:29.390] [WARN] [main] [FrameWork exist {}] java.lang.RuntimeException: com.oceanbase.oms.store.client.HttpBadResponseException: CmBaseException(oldErrorCode=0, errMsg=Found no active stores under topic [OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0], reason=null, relativeDocs=null) at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:93) at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:31) at com.oceanbase.connector.framework.threadmanager.TaskManager.start(TaskManager.java:49) at com.oceanbase.oms.connector.coordinator.BootStrapPanel.boot(BootStrapPanel.java:240) at com.oceanbase.oms.connector.jdbc.coordinator.Bootstrap.main(Bootstrap.java:44) Caused by: com.oceanbase.oms.store.client.HttpBadResponseException: CmBaseException(oldErrorCode=0, errMsg=Found no active stores under topic [OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0], reason=null, relativeDocs=null) at com.oceanbase.oms.store.client.impl.ServerProxy.askStore(ServerProxy.java:487) at com.oceanbase.oms.store.client.impl.ClusterManagers.findStore(ClusterManagers.java:101) at com.oceanbase.oms.store.client.impl.DRCClientImpl.connectClusterManager(DRCClientImpl.java:380) at com.oceanbase.oms.store.client.impl.DRCClientImpl.startService(DRCClientImpl.java:677) at com.oceanbase.oms.connector.source.store.StoreSource.start(StoreSource.java:159) at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:86) ... 4 common frames omitted [2025-09-16 16:55:29.395] [ERROR] [main] [main thread error] java.lang.RuntimeException: com.oceanbase.oms.store.client.HttpBadResponseException: CmBaseException(oldErrorCode=0, errMsg=Found no active stores under topic [OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0], reason=null, relativeDocs=null) at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:93) at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:31) at com.oceanbase.connector.framework.threadmanager.TaskManager.start(TaskManager.java:49) at com.oceanbase.oms.connector.coordinator.BootStrapPanel.boot(BootStrapPanel.java:240) at com.oceanbase.oms.connector.jdbc.coordinator.Bootstrap.main(Bootstrap.java:44) Caused by: com.oceanbase.oms.store.client.HttpBadResponseException: CmBaseException(oldErrorCode=0, errMsg=Found no active stores under topic [OB_MYSQL_CE_np_72zt6yn658v4_72ztssd2ue80-1-0], reason=null, relativeDocs=null) at com.oceanbase.oms.store.client.impl.ServerProxy.askStore(ServerProxy.java:487) at com.oceanbase.oms.store.client.impl.ClusterManagers.findStore(ClusterManagers.java:101) at com.oceanbase.oms.store.client.impl.DRCClientImpl.connectClusterManager(DRCClientImpl.java:380) at com.oceanbase.oms.store.client.impl.DRCClientImpl.startService(DRCClientImpl.java:677) at com.oceanbase.oms.connector.source.store.StoreSource.start(StoreSource.java:159) at com.oceanbase.connector.framework.threadmanager.sourcetask.SourceTaskManager.createConnectorTask(SourceTaskManager.java:86) ... 4 common frames omitted