[2024-12-20 14:23:19.070] [INFO] [main] [NativeFSLock: acquire with pid [32323]]
[2024-12-20 14:23:19.080] [INFO] [main] [error file not exists]
[2024-12-20 14:23:19.121] [INFO] [main] [system default timezone : GMT+08:00]
[2024-12-20 14:23:19.496] [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\":\"mysql.dh_ent_new\",\"map\":\"NONE\"}]",
    "whiteCondition" : "[{\"all\":false,\"sub\":[{\"name\":\"t_ent_abnormal\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_ent_base\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_ent_breaklaw\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_ent_business_customs_credit\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_ent_business_customs_credit_rating\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_ent_case\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_ent_case_credit\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_ent_change\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_ent_check\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_ent_investor\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_ent_ipr\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_ent_ipr_change\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_ent_jud_frozen\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_ent_jud_frozen_inval\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_ent_jud_frozen_keep\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_ent_jud_frozen_rem\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_ent_jud_shareholder_change\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_ent_judicial\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_ent_license\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_ent_license_credit\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_ent_license_pub\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_ent_liquidation\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_ent_mor_change\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_ent_mor_pawn\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_ent_mor_people\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_ent_mortgage\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_ent_rep_change\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_ent_rep_equity_change\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_ent_rep_guarantee\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_ent_rep_invest\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_ent_rep_shareholder\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_ent_rep_social_security\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_ent_rep_web\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_ent_report\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_ent_shareholder\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_ent_shareholder_pub\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_ent_staff\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_ent_stock_pawn\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_ent_tax_arrears\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_ent_tax_credit\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_ent_tax_illegal\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_judicial_be_performed\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_judicial_company_zxr_restrict\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_judicial_court_announcement\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_judicial_court_notices\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_judicial_court_register\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_judicial_defaulter\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_judicial_end_this_case\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_judicial_judgement\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_judicial_pccz_announcement\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_judicial_pccz_case_new\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_judicial_sale\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_judicial_send_announcement\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_judicial_trial_information_new\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"t_pid2\",\"map\":\"ob_increase_data_sync_test_topic\"},{\"name\":\"serious_trustbreach\",\"map\":\"ob_increase_data_sync_test_topic\"}],\"name\":\"mysql.dh_ent_new\",\"map\":\"NONE\"}]"
  }
}]
[2024-12-20 14:23:19.538] [INFO] [main] [map source class [com.oceanbase.oms.connector.source.store.MultiStoreSourceBooster] to [com.oceanbase.oms.connector.source.store.MultiStoreSourceBooster]]
[2024-12-20 14:23:19.541] [INFO] [main] [map sink class [com.oceanbase.oms.connector.rocketmq.sink.RocketMQSinkBooster] to [com.oceanbase.oms.connector.rocketmq.sink.RocketMQSinkBooster]]
[2024-12-20 14:23:19.572] [INFO] [main] [auto set coordinator config: {bridgeQueueSize=32, throttleMemoryBound=536870912} by metrics SMALL]
[2024-12-20 14:23:19.576] [INFO] [main] [auto set source config: {sourceBatchMemorySize=4194304, splitThreshold=32} by metrics SMALL]
[2024-12-20 14:23:19.599] [INFO] [main] [CastConfig: com.oceanbase.oms.connector.common.cast.CastConfig@37271612]
[2024-12-20 14:23:19.615] [INFO] [main] [OB_MYSQL_CE_ten_1_6c85sicl4eps-1-0-null-null is not valid]
[2024-12-20 14:23:19.615] [INFO] [main] [[condition]]
[2024-12-20 14:23:19.616] [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":"mysql.dh_ent_new","map":"NONE"}]]
[2024-12-20 14:23:19.616] [INFO] [main] [	whiteCondition = [{"all":false,"sub":[{"name":"t_ent_abnormal","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_base","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_breaklaw","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_business_customs_credit","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_business_customs_credit_rating","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_case","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_case_credit","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_change","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_check","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_investor","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_ipr","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_ipr_change","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_jud_frozen","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_jud_frozen_inval","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_jud_frozen_keep","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_jud_frozen_rem","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_jud_shareholder_change","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_judicial","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_license","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_license_credit","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_license_pub","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_liquidation","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_mor_change","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_mor_pawn","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_mor_people","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_mortgage","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_rep_change","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_rep_equity_change","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_rep_guarantee","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_rep_invest","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_rep_shareholder","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_rep_social_security","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_rep_web","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_report","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_shareholder","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_shareholder_pub","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_staff","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_stock_pawn","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_tax_arrears","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_tax_credit","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_tax_illegal","map":"ob_increase_data_sync_test_topic"},{"name":"t_judicial_be_performed","map":"ob_increase_data_sync_test_topic"},{"name":"t_judicial_company_zxr_restrict","map":"ob_increase_data_sync_test_topic"},{"name":"t_judicial_court_announcement","map":"ob_increase_data_sync_test_topic"},{"name":"t_judicial_court_notices","map":"ob_increase_data_sync_test_topic"},{"name":"t_judicial_court_register","map":"ob_increase_data_sync_test_topic"},{"name":"t_judicial_defaulter","map":"ob_increase_data_sync_test_topic"},{"name":"t_judicial_end_this_case","map":"ob_increase_data_sync_test_topic"},{"name":"t_judicial_judgement","map":"ob_increase_data_sync_test_topic"},{"name":"t_judicial_pccz_announcement","map":"ob_increase_data_sync_test_topic"},{"name":"t_judicial_pccz_case_new","map":"ob_increase_data_sync_test_topic"},{"name":"t_judicial_sale","map":"ob_increase_data_sync_test_topic"},{"name":"t_judicial_send_announcement","map":"ob_increase_data_sync_test_topic"},{"name":"t_judicial_trial_information_new","map":"ob_increase_data_sync_test_topic"},{"name":"t_pid2","map":"ob_increase_data_sync_test_topic"},{"name":"serious_trustbreach","map":"ob_increase_data_sync_test_topic"}],"name":"mysql.dh_ent_new","map":"NONE"}]]
[2024-12-20 14:23:19.616] [INFO] [main] [[coordinator]]
[2024-12-20 14:23:19.616] [INFO] [main] [	taskIdentity = np_6c85s7mabli8]
[2024-12-20 14:23:19.616] [INFO] [main] [	enableOmsConnectorV2Report = true]
[2024-12-20 14:23:19.616] [INFO] [main] [	isCaseSensitive = false]
[2024-12-20 14:23:19.616] [INFO] [main] [	dbTableCaseStrategy = follow-source]
[2024-12-20 14:23:19.616] [INFO] [main] [	streamMode = true]
[2024-12-20 14:23:19.616] [INFO] [main] [	timezone = +08:00]
[2024-12-20 14:23:19.617] [INFO] [main] [	enableActiveReportTask = false]
[2024-12-20 14:23:19.617] [INFO] [main] [	bridgeQueueSize = 32]
[2024-12-20 14:23:19.617] [INFO] [main] [	ignoreDdl = true]
[2024-12-20 14:23:19.617] [INFO] [main] [	shuffleDdlToAllRoute = true]
[2024-12-20 14:23:19.617] [INFO] [main] [	enableMetricReportTask = false]
[2024-12-20 14:23:19.617] [INFO] [main] [	sourceType = OB_MYSQL]
[2024-12-20 14:23:19.617] [INFO] [main] [	columnCaseStrategy = follow-source]
[2024-12-20 14:23:19.617] [INFO] [main] [	throttleMemoryBound = 536870912]
[2024-12-20 14:23:19.617] [INFO] [main] [	sinkType = ROCKETMQ]
[2024-12-20 14:23:19.617] [INFO] [main] [	listenPort = 16000]
[2024-12-20 14:23:19.617] [INFO] [main] [	allowRecordTypes = INSERT,UPDATE]
[2024-12-20 14:23:19.617] [INFO] [main] [	ignoreCompensateDDL = false]
[2024-12-20 14:23:19.617] [INFO] [main] [	connectorJvmParam = -Xms2048m -Xmx2048m -Xmn1024m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=128m -XX:+UseConcMarkSweepGC -XX:+UseParNewGC -XX:+CMSParallelRemarkEnabled -XX:+UseCMSInitiatingOccupancyOnly -XX:CMSInitiatingOccupancyFraction=70 -XX:+CMSClassUnloadingEnabled]
[2024-12-20 14:23:19.617] [INFO] [main] [[sink]]
[2024-12-20 14:23:19.617] [INFO] [main] [	boosterClass = com.oceanbase.oms.connector.rocketmq.sink.RocketMQSinkBooster]
[2024-12-20 14:23:19.618] [INFO] [main] [	enableNoUniqueConstraintTableReplicate = false]
[2024-12-20 14:23:19.618] [INFO] [main] [	dbTableCaseStrategy = follow-source]
[2024-12-20 14:23:19.618] [INFO] [main] [	serializerType = DEFAULT]
[2024-12-20 14:23:19.618] [INFO] [main] [	filterHiddenPK = false]
[2024-12-20 14:23:19.618] [INFO] [main] [	partitionMode = HASH]
[2024-12-20 14:23:19.618] [INFO] [main] [	nameSvrAddr = 172.16.20.190:9876;172.16.20.103:9876]
[2024-12-20 14:23:19.618] [INFO] [main] [	type = ROCKETMQ_SINK]
[2024-12-20 14:23:19.618] [INFO] [main] [	ignoreDdl = true]
[2024-12-20 14:23:19.618] [INFO] [main] [	ignoreConflictDetectOfNullValue = true]
[2024-12-20 14:23:19.618] [INFO] [main] [	producerGroup = ob_increase_data_sync_provider_group]
[2024-12-20 14:23:19.619] [INFO] [main] [	columnCaseStrategy = follow-source]
[2024-12-20 14:23:19.619] [INFO] [main] [	sinkMaps = [["NONE","ob_increase_data_sync_test_topic"]]]
[2024-12-20 14:23:19.619] [INFO] [main] [	ignoreRedunantColumnsReplicate = false]
[2024-12-20 14:23:19.619] [INFO] [main] [	jar = rocketmq_sink-sink.jar]
[2024-12-20 14:23:19.619] [INFO] [main] [	sinkType = ROCKETMQ]
[2024-12-20 14:23:19.619] [INFO] [main] [[source]]
[2024-12-20 14:23:19.619] [INFO] [main] [	checkpoint = {"OB_MYSQL_CE_ten_1_6c85sicl4eps-1-0":"1734532200"}]
[2024-12-20 14:23:19.619] [INFO] [main] [	boosterClass = com.oceanbase.oms.connector.source.store.MultiStoreSourceBooster]
[2024-12-20 14:23:19.619] [INFO] [main] [	taskIdentity = np_6c85s7mabli8]
[2024-12-20 14:23:19.619] [INFO] [main] [	enableOmsConnectorV2Report = true]
[2024-12-20 14:23:19.619] [INFO] [main] [	clients = [{"clientId":"OB_MYSQL_CE_ten_1_6c85sicl4eps-1-0","clusterManagerUrl":"http://172.16.20.200:8088","subtopic":"OB_MYSQL_CE_ten_1_6c85sicl4eps-1-0"}]]
[2024-12-20 14:23:19.619] [INFO] [main] [	dbVersion = 4.2.1.7]
[2024-12-20 14:23:19.619] [INFO] [main] [	timezone = +08:00]
[2024-12-20 14:23:19.619] [INFO] [main] [	dbType = OB_MYSQL]
[2024-12-20 14:23:19.620] [INFO] [main] [	taskSubId = 1]
[2024-12-20 14:23:19.620] [INFO] [main] [	type = STORE_SOURCE]
[2024-12-20 14:23:19.620] [INFO] [main] [	sourceBatchMemorySize = 4194304]
[2024-12-20 14:23:19.620] [INFO] [main] [	ignoreDdl = true]
[2024-12-20 14:23:19.620] [INFO] [main] [	password = RM_oms]
[2024-12-20 14:23:19.620] [INFO] [main] [	taskType = migrate]
[2024-12-20 14:23:19.620] [INFO] [main] [	jar = connector-source-store.jar]
[2024-12-20 14:23:19.620] [INFO] [main] [	username = RM_oms]
[2024-12-20 14:23:19.620] [INFO] [main] [	splitThreshold = 32]
[2024-12-20 14:23:19.668] [INFO] [main] [store config: {
  "checkpoint" : "{\"OB_MYSQL_CE_ten_1_6c85sicl4eps-1-0\":\"1734532200\"}",
  "boosterClass" : "com.oceanbase.oms.connector.source.store.MultiStoreSourceBooster",
  "taskIdentity" : "np_6c85s7mabli8",
  "enableOmsConnectorV2Report" : "true",
  "clients" : "[{\"clientId\":\"OB_MYSQL_CE_ten_1_6c85sicl4eps-1-0\",\"clusterManagerUrl\":\"http://172.16.20.200:8088\",\"subtopic\":\"OB_MYSQL_CE_ten_1_6c85sicl4eps-1-0\"}]",
  "dbVersion" : "4.2.1.7",
  "timezone" : "+08:00",
  "dbType" : "OB_MYSQL",
  "taskSubId" : "1",
  "type" : "STORE_SOURCE",
  "sourceBatchMemorySize" : "4194304",
  "connectionTimeoutSec" : "120",
  "ignoreDdl" : "true",
  "askSelfUnit" : "false",
  "password" : "RM_oms",
  "taskType" : "migrate",
  "maxRetries" : "1000",
  "transactionEnabled" : "false",
  "jar" : "connector-source-store.jar",
  "username" : "RM_oms",
  "splitThreshold" : "32"
}]
[2024-12-20 14:23:19.678] [INFO] [main] [rocketmq config: {
  "boosterClass" : "com.oceanbase.oms.connector.rocketmq.sink.RocketMQSinkBooster",
  "filterHiddenPK" : "false",
  "clientCallbackExecutorThreadsNum" : "-1",
  "partitionMode" : "HASH",
  "type" : "ROCKETMQ_SINK",
  "nameSvrAddr" : "172.16.20.190:9876;172.16.20.103:9876",
  "ignoreDdl" : "true",
  "ignoreConflictDetectOfNullValue" : "true",
  "producerGroup" : "ob_increase_data_sync_provider_group",
  "lingerMs" : "1000",
  "columnCaseStrategy" : "follow-source",
  "sinkMaps" : "[[\"NONE\",\"ob_increase_data_sync_test_topic\"]]",
  "jar" : "rocketmq_sink-sink.jar",
  "sendMsgTimeout" : "30000",
  "nameSpace" : "",
  "clientThreadCount" : "-1",
  "enableNoUniqueConstraintTableReplicate" : "false",
  "dbTableCaseStrategy" : "follow-source",
  "serializerType" : "DEFAULT",
  "maxRetryTimes" : "1000",
  "retryIntervalTime" : "1000",
  "shardFuncClassName" : "com.oceanbase.oms.connector.rocketmq.sink.RocketMQShardFunc",
  "ignoreRedunantColumnsReplicate" : "false",
  "enableTrace" : "false",
  "sinkType" : "ROCKETMQ",
  "workerNum" : "16"
}]
[2024-12-20 14:23:19.687] [INFO] [main] [build rocketmq producer. nameSvrAdd: 172.16.20.190:9876;172.16.20.103:9876, groupName: ob_increase_data_sync_provider_group]
[2024-12-20 14:23:19.711] [INFO] [main] [start rocketmq producer. nameSvrAdd: 172.16.20.190:9876;172.16.20.103:9876, groupName: ob_increase_data_sync_provider_group]
[2024-12-20 14:23:19.860] [INFO] [main] [dbVersion is empty]
[2024-12-20 14:23:19.867] [INFO] [main] [auto set coordinator config: {shuffleMinBatchSize=10, shuffleMaxBatchSize=20, shuffleFlushIntervalMs=10, shuffleBucketSize=32} by metrics SMALL]
[2024-12-20 14:23:19.868] [INFO] [main] [put coordinator.maxRecordCapacity: batchSize(32), workerNum(16), maxRecordCapacity: 16384, may have been set, so it's inconsistent with cal value ]
[2024-12-20 14:23:19.875] [INFO] [main] [build rocketmq producer. nameSvrAdd: 172.16.20.190:9876;172.16.20.103:9876, groupName: ob_increase_data_sync_provider_group]
[2024-12-20 14:23:20.253] [INFO] [main] [Init sinkRouteMapper: {ob_increase_data_sync_test_topic=[ob_increase_data_sync_test_topic@broker-a@0, ob_increase_data_sync_test_topic@broker-a@1, ob_increase_data_sync_test_topic@broker-a@2, ob_increase_data_sync_test_topic@broker-a@3, ob_increase_data_sync_test_topic@broker-b@0, ob_increase_data_sync_test_topic@broker-b@1, ob_increase_data_sync_test_topic@broker-b@2, ob_increase_data_sync_test_topic@broker-b@3]}]
[2024-12-20 14:23:20.286] [INFO] [main] [Build ShardBucket: with minBatchSize: [10], maxBatchSize [20], flushIntervalMs [10], inFlightBatchSize [1]]
[2024-12-20 14:23:20.287] [INFO] [main] [ShuffleRecordDispatcher: start with capacity [16384], shardBucketCounts [32], minBatchSize [10]]
[2024-12-20 14:23:20.287] [INFO] [main] [ShuffleRecordDispatcher: start with batchMode, flushBatchInterval [10]]
[2024-12-20 14:23:20.444] [INFO] [main] [ConcurrentArrayQueue mod MULTI_PRODUCER_MULTI_CONSUMER, size: 32]
[2024-12-20 14:23:20.458] [INFO] [main] [ConcurrentArrayQueue mod MULTI_PRODUCER_MULTI_CONSUMER, size: 32]
[2024-12-20 14:23:20.510] [INFO] [main] [[condition]]
[2024-12-20 14:23:20.511] [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":"mysql.dh_ent_new","map":"NONE"}]]
[2024-12-20 14:23:20.511] [INFO] [main] [	whiteCondition = [{"all":false,"sub":[{"name":"t_ent_abnormal","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_base","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_breaklaw","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_business_customs_credit","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_business_customs_credit_rating","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_case","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_case_credit","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_change","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_check","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_investor","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_ipr","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_ipr_change","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_jud_frozen","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_jud_frozen_inval","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_jud_frozen_keep","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_jud_frozen_rem","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_jud_shareholder_change","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_judicial","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_license","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_license_credit","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_license_pub","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_liquidation","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_mor_change","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_mor_pawn","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_mor_people","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_mortgage","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_rep_change","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_rep_equity_change","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_rep_guarantee","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_rep_invest","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_rep_shareholder","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_rep_social_security","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_rep_web","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_report","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_shareholder","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_shareholder_pub","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_staff","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_stock_pawn","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_tax_arrears","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_tax_credit","map":"ob_increase_data_sync_test_topic"},{"name":"t_ent_tax_illegal","map":"ob_increase_data_sync_test_topic"},{"name":"t_judicial_be_performed","map":"ob_increase_data_sync_test_topic"},{"name":"t_judicial_company_zxr_restrict","map":"ob_increase_data_sync_test_topic"},{"name":"t_judicial_court_announcement","map":"ob_increase_data_sync_test_topic"},{"name":"t_judicial_court_notices","map":"ob_increase_data_sync_test_topic"},{"name":"t_judicial_court_register","map":"ob_increase_data_sync_test_topic"},{"name":"t_judicial_defaulter","map":"ob_increase_data_sync_test_topic"},{"name":"t_judicial_end_this_case","map":"ob_increase_data_sync_test_topic"},{"name":"t_judicial_judgement","map":"ob_increase_data_sync_test_topic"},{"name":"t_judicial_pccz_announcement","map":"ob_increase_data_sync_test_topic"},{"name":"t_judicial_pccz_case_new","map":"ob_increase_data_sync_test_topic"},{"name":"t_judicial_sale","map":"ob_increase_data_sync_test_topic"},{"name":"t_judicial_send_announcement","map":"ob_increase_data_sync_test_topic"},{"name":"t_judicial_trial_information_new","map":"ob_increase_data_sync_test_topic"},{"name":"t_pid2","map":"ob_increase_data_sync_test_topic"},{"name":"serious_trustbreach","map":"ob_increase_data_sync_test_topic"}],"name":"mysql.dh_ent_new","map":"NONE"}]]
[2024-12-20 14:23:20.511] [INFO] [main] [[coordinator]]
[2024-12-20 14:23:20.512] [INFO] [main] [	enableOmsConnectorV2Report = true]
[2024-12-20 14:23:20.512] [INFO] [main] [	streamMode = true]
[2024-12-20 14:23:20.512] [INFO] [main] [	timezone = +08:00]
[2024-12-20 14:23:20.512] [INFO] [main] [	shuffleBucketMaxInFlightBatchSize = 1]
[2024-12-20 14:23:20.512] [INFO] [main] [	bridgeQueueSize = 32]
[2024-12-20 14:23:20.512] [INFO] [main] [	shuffleFlushIntervalMs = 10]
[2024-12-20 14:23:20.512] [INFO] [main] [	ignoreDdl = true]
[2024-12-20 14:23:20.513] [INFO] [main] [	enableMetricReportTask = false]
[2024-12-20 14:23:20.513] [INFO] [main] [	columnCaseStrategy = follow-source]
[2024-12-20 14:23:20.513] [INFO] [main] [	ignoreCompensateDDL = false]
[2024-12-20 14:23:20.513] [INFO] [main] [	shuffleMinBatchSize = 10]
[2024-12-20 14:23:20.513] [INFO] [main] [	taskIdentity = np_6c85s7mabli8]
[2024-12-20 14:23:20.513] [INFO] [main] [	isCaseSensitive = false]
[2024-12-20 14:23:20.513] [INFO] [main] [	dbTableCaseStrategy = follow-source]
[2024-12-20 14:23:20.513] [INFO] [main] [	shuffleBucketSize = 32]
[2024-12-20 14:23:20.513] [INFO] [main] [	maxRecordCapacity = 16384]
[2024-12-20 14:23:20.513] [INFO] [main] [	enableActiveReportTask = false]
[2024-12-20 14:23:20.513] [INFO] [main] [	shuffleMaxBatchSize = 20]
[2024-12-20 14:23:20.514] [INFO] [main] [	shuffleDdlToAllRoute = true]
[2024-12-20 14:23:20.514] [INFO] [main] [	sourceType = OB_MYSQL]
[2024-12-20 14:23:20.514] [INFO] [main] [	throttleMemoryBound = 536870912]
[2024-12-20 14:23:20.514] [INFO] [main] [	sinkType = ROCKETMQ]
[2024-12-20 14:23:20.514] [INFO] [main] [	dispatcherClassName = com.oceanbase.oms.connector.dispatcher.shard.ShuffleRecordDispatcher]
[2024-12-20 14:23:20.514] [INFO] [main] [	listenPort = 16000]
[2024-12-20 14:23:20.514] [INFO] [main] [	allowRecordTypes = INSERT,UPDATE]
[2024-12-20 14:23:20.514] [INFO] [main] [	connectorJvmParam = -Xms2048m -Xmx2048m -Xmn1024m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=128m -XX:+UseConcMarkSweepGC -XX:+UseParNewGC -XX:+CMSParallelRemarkEnabled -XX:+UseCMSInitiatingOccupancyOnly -XX:CMSInitiatingOccupancyFraction=70 -XX:+CMSClassUnloadingEnabled]
[2024-12-20 14:23:20.514] [INFO] [main] [[sink]]
[2024-12-20 14:23:20.515] [INFO] [main] [	boosterClass = com.oceanbase.oms.connector.rocketmq.sink.RocketMQSinkBooster]
[2024-12-20 14:23:20.515] [INFO] [main] [	enableNoUniqueConstraintTableReplicate = false]
[2024-12-20 14:23:20.515] [INFO] [main] [	dbTableCaseStrategy = follow-source]
[2024-12-20 14:23:20.515] [INFO] [main] [	serializerType = DEFAULT]
[2024-12-20 14:23:20.515] [INFO] [main] [	filterHiddenPK = false]
[2024-12-20 14:23:20.515] [INFO] [main] [	partitionMode = HASH]
[2024-12-20 14:23:20.515] [INFO] [main] [	nameSvrAddr = 172.16.20.190:9876;172.16.20.103:9876]
[2024-12-20 14:23:20.515] [INFO] [main] [	type = ROCKETMQ_SINK]
[2024-12-20 14:23:20.516] [INFO] [main] [	ignoreDdl = true]
[2024-12-20 14:23:20.516] [INFO] [main] [	ignoreConflictDetectOfNullValue = true]
[2024-12-20 14:23:20.516] [INFO] [main] [	producerGroup = ob_increase_data_sync_provider_group]
[2024-12-20 14:23:20.516] [INFO] [main] [	columnCaseStrategy = follow-source]
[2024-12-20 14:23:20.516] [INFO] [main] [	sinkMaps = [["NONE","ob_increase_data_sync_test_topic"]]]
[2024-12-20 14:23:20.516] [INFO] [main] [	ignoreRedunantColumnsReplicate = false]
[2024-12-20 14:23:20.516] [INFO] [main] [	jar = rocketmq_sink-sink.jar]
[2024-12-20 14:23:20.516] [INFO] [main] [	enableTransactionWriter = false]
[2024-12-20 14:23:20.517] [INFO] [main] [	sinkType = ROCKETMQ]
[2024-12-20 14:23:20.517] [INFO] [main] [[source]]
[2024-12-20 14:23:20.518] [INFO] [main] [	checkpoint = {"OB_MYSQL_CE_ten_1_6c85sicl4eps-1-0":"1734532200"}]
[2024-12-20 14:23:20.518] [INFO] [main] [	boosterClass = com.oceanbase.oms.connector.source.store.MultiStoreSourceBooster]
[2024-12-20 14:23:20.518] [INFO] [main] [	taskIdentity = np_6c85s7mabli8]
[2024-12-20 14:23:20.519] [INFO] [main] [	enableOmsConnectorV2Report = true]
[2024-12-20 14:23:20.519] [INFO] [main] [	clients = [{"clientId":"OB_MYSQL_CE_ten_1_6c85sicl4eps-1-0","clusterManagerUrl":"http://172.16.20.200:8088","subtopic":"OB_MYSQL_CE_ten_1_6c85sicl4eps-1-0"}]]
[2024-12-20 14:23:20.519] [INFO] [main] [	dbVersion = 4.2.1.7]
[2024-12-20 14:23:20.519] [INFO] [main] [	timezone = +08:00]
[2024-12-20 14:23:20.519] [INFO] [main] [	dbType = OB_MYSQL]
[2024-12-20 14:23:20.519] [INFO] [main] [	taskSubId = 1]
[2024-12-20 14:23:20.519] [INFO] [main] [	type = STORE_SOURCE]
[2024-12-20 14:23:20.519] [INFO] [main] [	sourceBatchMemorySize = 4194304]
[2024-12-20 14:23:20.519] [INFO] [main] [	ignoreDdl = true]
[2024-12-20 14:23:20.519] [INFO] [main] [	password = RM_oms]
[2024-12-20 14:23:20.519] [INFO] [main] [	taskType = migrate]
[2024-12-20 14:23:20.519] [INFO] [main] [	jar = connector-source-store.jar]
[2024-12-20 14:23:20.520] [INFO] [main] [	username = RM_oms]
[2024-12-20 14:23:20.520] [INFO] [main] [	splitThreshold = 32]
[2024-12-20 14:23:20.535] [INFO] [main] [BootStrap: init memoryBoound value to 536870912]
[2024-12-20 14:23:20.641] [INFO] [main] [BootStrapPanel: register keep alive url [/status]]
[2024-12-20 14:23:20.644] [INFO] [main] [BootStrapPanel: register source stats url [/source/stats]]
[2024-12-20 14:23:20.647] [INFO] [main] [BootStrapPanel: register checkpoint query url [/checkpoint/query]]
[2024-12-20 14:23:20.649] [INFO] [main] [BootStrapPanel: register throttle control url [/throttle/control]]
[2024-12-20 14:23:20.652] [INFO] [main] [BootStrapPanel: register throttle query url [/throttle/query]]
[2024-12-20 14:23:20.753] [INFO] [main] [storeSource config: {checkpoint={"OB_MYSQL_CE_ten_1_6c85sicl4eps-1-0":"1734532200"}, useDRCNet=true, cmUrl=http://172.16.20.200:8088, storePassword=RM_oms, boosterClass=com.oceanbase.oms.connector.source.store.MultiStoreSourceBooster, enableOmsConnectorV2Report=true, clients=[{"clientId":"OB_MYSQL_CE_ten_1_6c85sicl4eps-1-0","clusterManagerUrl":"http://172.16.20.200:8088","subtopic":"OB_MYSQL_CE_ten_1_6c85sicl4eps-1-0"}], timezone=+08:00, storeEnableTransactionSeq=false, type=STORE_SOURCE, sourceBatchMemorySize=4194304, ignoreDdl=true, password=RM_oms, taskType=migrate, storeTimeoutSec=120, jar=connector-source-store.jar, timestamp=1734532200, taskIdentity=np_6c85s7mabli8, srcSubTopic=OB_MYSQL_CE_ten_1_6c85sicl4eps-1-0, clientId=OB_MYSQL_CE_ten_1_6c85sicl4eps-1-0, dbVersion=4.2.1.7, dbType=OB_MYSQL, taskSubId=1, storeRetryTimes=1000, storeUsername=RM_oms, askSelfUnit=false, storeBlackFilterStr=mysql.dh_ent_new.drc_txn*|mysql.dh_ent_new.delay_delete_*, storeWhiteFilterStr=mysql.dh_ent_new.t_judicial_court_notices|mysql.dh_ent_new.t_ent_tax_credit|mysql.dh_ent_new.t_judicial_court_announcement|mysql.dh_ent_new.t_judicial_sale|mysql.dh_ent_new.t_pid2|mysql.dh_ent_new.t_ent_judicial|mysql.dh_ent_new.t_judicial_send_announcement|mysql.dh_ent_new.t_judicial_trial_information_new|mysql.dh_ent_new.t_ent_report|mysql.dh_ent_new.t_ent_investor|mysql.dh_ent_new.t_ent_liquidation|mysql.dh_ent_new.t_ent_rep_web|mysql.dh_ent_new.t_ent_rep_equity_change|mysql.dh_ent_new.t_ent_staff|mysql.dh_ent_new.t_ent_check|mysql.dh_ent_new.t_judicial_pccz_case_new|mysql.dh_ent_new.t_ent_jud_shareholder_change|mysql.dh_ent_new.t_ent_business_customs_credit_rating|mysql.dh_ent_new.t_ent_mor_people|mysql.dh_ent_new.serious_trustbreach|mysql.dh_ent_new.t_ent_license_credit|mysql.dh_ent_new.t_ent_rep_change|mysql.dh_ent_new.t_judicial_pccz_announcement|mysql.dh_ent_new.t_ent_case|mysql.dh_ent_new.t_ent_rep_shareholder|mysql.dh_ent_new.t_judicial_company_zxr_restrict|mysql.dh_ent_new.t_judicial_judgement|mysql.dh_ent_new.t_ent_tax_illegal|mysql.dh_ent_new.t_judicial_be_performed|mysql.dh_ent_new.t_judicial_end_this_case|mysql.dh_ent_new.t_ent_case_credit|mysql.dh_ent_new.t_ent_jud_frozen_rem|mysql.dh_ent_new.t_ent_business_customs_credit|mysql.dh_ent_new.t_ent_rep_invest|mysql.dh_ent_new.t_ent_tax_arrears|mysql.dh_ent_new.t_ent_mor_change|mysql.dh_ent_new.t_ent_jud_frozen_inval|mysql.dh_ent_new.t_ent_ipr_change|mysql.dh_ent_new.t_ent_license_pub|mysql.dh_ent_new.t_ent_abnormal|mysql.dh_ent_new.t_ent_ipr|mysql.dh_ent_new.t_judicial_defaulter|mysql.dh_ent_new.t_ent_base|mysql.dh_ent_new.t_ent_rep_social_security|mysql.dh_ent_new.t_ent_jud_frozen_keep|mysql.dh_ent_new.t_judicial_court_register|mysql.dh_ent_new.t_ent_change|mysql.dh_ent_new.t_ent_license|mysql.dh_ent_new.t_ent_shareholder_pub|mysql.dh_ent_new.t_ent_jud_frozen|mysql.dh_ent_new.t_ent_mortgage|mysql.dh_ent_new.t_ent_stock_pawn|mysql.dh_ent_new.t_ent_breaklaw|mysql.dh_ent_new.t_ent_rep_guarantee|mysql.dh_ent_new.t_ent_shareholder|mysql.dh_ent_new.t_ent_mor_pawn, username=RM_oms, splitThreshold=32}]
[2024-12-20 14:23:20.758] [INFO] [main] [start transaction assembler]
[2024-12-20 14:23:20.758] [WARN] [main] [StoreSource: cache enabled[false]]
[2024-12-20 14:23:20.769] [INFO] [main] [useCheckpointListener: true]
[2024-12-20 14:23:20.834] [INFO] [main] [useSchemaCache: false, useBetaListener: false]
[2024-12-20 14:23:20.834] [INFO] [main] [create drc client with config: {client.connectionTimeout=120, binlogPassword=RM_oms, subTopic=OB_MYSQL_CE_ten_1_6c85sicl4eps-1-0, client.socketTimeout=120, askSelfUnit=false, manager.host=http://172.16.20.200:8088, client.requireCompleteTxn=false, timestamp=1734532200, binlogUsername=RM_oms, useDrcNet=true, server.messageType=binary, server.maxRetriedTimes=1000}]
[2024-12-20 14:23:20.857] [INFO] [main] [Initialize the service with starting point: 1734532200]
[2024-12-20 14:23:20.857] [INFO] [main] [drc client started]
[2024-12-20 14:23:20.857] [INFO] [main] [store source crawler info is {crawler=null, drcConfig={subTopic=OB_MYSQL_CE_ten_1_6c85sicl4eps-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://172.16.20.200:8088, timestamp=1734532200}, store=null}]
[2024-12-20 14:23:20.864] [INFO] [main] [start drc client]
[2024-12-20 14:23:21.859] [WARN] [main] [drcnet client read timeout: 120]
[2024-12-20 14:23:21.916] [INFO] [nioEventLoopGroup-2-1] [get server version 2]
[2024-12-20 14:23:21.921] [INFO] [nioEventLoopGroup-2-1] [alloc id=1, server buf size: 1048576]
[2024-12-20 14:23:21.923] [WARN] [nioEventLoopGroup-2-1] [recv buf size is:1053696]
[2024-12-20 14:23:21.925] [WARN] [nioEventLoopGroup-2-1] [cache buf size is: 1048576]
[2024-12-20 14:23:21.925] [WARN] [nioEventLoopGroup-2-1] [cache buf size is: 1048576]
[2024-12-20 14:23:21.926] [WARN] [nioEventLoopGroup-2-1] [single conn start]
[2024-12-20 14:23:21.928] [INFO] [nioEventLoopGroup-2-1] [accept]
[2024-12-20 14:23:22.879] [INFO] [main] [Connect to http://172.16.20.200:17002/OB_MYSQL_CE_ten_1_6c85sicl4eps-1-0 successfully]
[2024-12-20 14:23:22.880] [INFO] [main] [start service successfully]
[2024-12-20 14:23:22.880] [INFO] [main] [getting data from daemon server]
[2024-12-20 14:24:31.823] [INFO] [DRC-Client-Thread] [notify consume: 2.5 ms]
[2024-12-20 14:27:04.831] [ERROR] [nioEventLoopGroup-2-1] [null]
io.netty.handler.timeout.ReadTimeoutException: null
[2024-12-20 14:27:04.833] [WARN] [nioEventLoopGroup-2-1] [connection closed]
[2024-12-20 14:27:06.834] [WARN] [nioEventLoopGroup-2-1] [drcnet stopping...,drcnet recv buffer is set stopped, ignore data from netty]
[2024-12-20 14:27:06.899] [WARN] [nioEventLoopGroup-2-1] [connection is stopped]
[2024-12-20 14:27:06.900] [INFO] [DRC-Client-Thread] [Connect to http://172.16.20.200:17002/OB_MYSQL_CE_ten_1_6c85sicl4eps-1-0 failed because read drcnet failed, server shutdown]
[2024-12-20 14:27:06.900] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.ServerProxy.getDrcNetResponse(ServerProxy.java:246)]
[2024-12-20 14:27:06.900] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.DRCClientImpl.run(DRCClientImpl.java:439)]
[2024-12-20 14:27:06.901] [INFO] [DRC-Client-Thread] [java.lang.Thread.run(Thread.java:853)]
[2024-12-20 14:27:06.901] [WARN] [nioEventLoopGroup-2-1] [drcnet stopping...,drcnet recv buffer is set stopped, ignore data from netty]
[2024-12-20 14:27:06.901] [WARN] [nioEventLoopGroup-2-1] [connection is stopped]
[2024-12-20 14:27:06.901] [INFO] [DRC-Client-Thread] [After broken, retry cluster manager 1 out of 1]
[2024-12-20 14:27:06.901] [INFO] [DRC-Client-Thread] [Redirect to taskName: OB_MYSQL_CE_ten_1_6c85sicl4eps-1-0]
[2024-12-20 14:27:16.975] [INFO] [DRC-Client-Thread] [Connect to http://172.16.20.200:17002/OB_MYSQL_CE_ten_1_6c85sicl4eps-1-0 failed because CmBaseException(oldErrorCode=0, errMsg=Found no active stores under topic [OB_MYSQL_CE_ten_1_6c85sicl4eps-1-0], reason=null, relativeDocs=null)]
[2024-12-20 14:27:16.976] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.ServerProxy.askStore(ServerProxy.java:487)]
[2024-12-20 14:27:16.976] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.ClusterManagers.findStore(ClusterManagers.java:101)]
[2024-12-20 14:27:16.976] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.DRCClientImpl.connectClusterManager(DRCClientImpl.java:380)]
[2024-12-20 14:27:16.976] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.DRCClientImpl.processRedirectMessage(DRCClientImpl.java:660)]
[2024-12-20 14:27:16.976] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.DRCClientImpl.run(DRCClientImpl.java:446)]
[2024-12-20 14:27:16.976] [INFO] [DRC-Client-Thread] [java.lang.Thread.run(Thread.java:853)]
[2024-12-20 14:27:16.976] [INFO] [DRC-Client-Thread] [After broken, retry cluster manager 2 out of 2]
[2024-12-20 14:27:16.976] [INFO] [DRC-Client-Thread] [Redirect to taskName: OB_MYSQL_CE_ten_1_6c85sicl4eps-1-0]
[2024-12-20 14:27:27.051] [INFO] [DRC-Client-Thread] [Connect to http://172.16.20.200:17002/OB_MYSQL_CE_ten_1_6c85sicl4eps-1-0 failed because CmBaseException(oldErrorCode=0, errMsg=Found no active stores under topic [OB_MYSQL_CE_ten_1_6c85sicl4eps-1-0], reason=null, relativeDocs=null)]
[2024-12-20 14:27:27.051] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.ServerProxy.askStore(ServerProxy.java:487)]
[2024-12-20 14:27:27.051] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.ClusterManagers.findStore(ClusterManagers.java:101)]
[2024-12-20 14:27:27.051] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.DRCClientImpl.connectClusterManager(DRCClientImpl.java:380)]
[2024-12-20 14:27:27.051] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.DRCClientImpl.processRedirectMessage(DRCClientImpl.java:660)]
[2024-12-20 14:27:27.051] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.DRCClientImpl.run(DRCClientImpl.java:446)]
[2024-12-20 14:27:27.051] [INFO] [DRC-Client-Thread] [java.lang.Thread.run(Thread.java:853)]
[2024-12-20 14:27:27.052] [INFO] [DRC-Client-Thread] [After broken, retry cluster manager 3 out of 3]
[2024-12-20 14:27:27.052] [INFO] [DRC-Client-Thread] [Redirect to taskName: OB_MYSQL_CE_ten_1_6c85sicl4eps-1-0]
[2024-12-20 14:27:37.125] [INFO] [DRC-Client-Thread] [Connect to http://172.16.20.200:17002/OB_MYSQL_CE_ten_1_6c85sicl4eps-1-0 failed because CmBaseException(oldErrorCode=0, errMsg=Found no active stores under topic [OB_MYSQL_CE_ten_1_6c85sicl4eps-1-0], reason=null, relativeDocs=null)]
[2024-12-20 14:27:37.126] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.ServerProxy.askStore(ServerProxy.java:487)]
[2024-12-20 14:27:37.126] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.ClusterManagers.findStore(ClusterManagers.java:101)]
[2024-12-20 14:27:37.126] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.DRCClientImpl.connectClusterManager(DRCClientImpl.java:380)]
[2024-12-20 14:27:37.126] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.DRCClientImpl.processRedirectMessage(DRCClientImpl.java:660)]
[2024-12-20 14:27:37.126] [INFO] [DRC-Client-Thread] [com.oceanbase.oms.store.client.impl.DRCClientImpl.run(DRCClientImpl.java:446)]
[2024-12-20 14:27:37.126] [INFO] [DRC-Client-Thread] [java.lang.Thread.run(Thread.java:853)]
[2024-12-20 14:27:37.127] [INFO] [DRC-Client-Thread] [After broken, retry cluster manager 4 out of 4]
[2024-12-20 14:27:37.127] [INFO] [DRC-Client-Thread] [Redirect to taskName: OB_MYSQL_CE_ten_1_6c85sicl4eps-1-0]
[2024-12-20 14:27:47.227] [WARN] [DRC-Client-Thread] [drcnet client read timeout: 120]
[2024-12-20 14:27:47.236] [INFO] [nioEventLoopGroup-3-1] [get server version 2]
[2024-12-20 14:27:47.237] [INFO] [nioEventLoopGroup-3-1] [alloc id=2, server buf size: 1048576]
[2024-12-20 14:27:47.239] [WARN] [nioEventLoopGroup-3-1] [recv buf size is:1053696]
[2024-12-20 14:27:47.239] [WARN] [nioEventLoopGroup-3-1] [cache buf size is: 1048576]
[2024-12-20 14:27:47.240] [WARN] [nioEventLoopGroup-3-1] [cache buf size is: 1048576]
[2024-12-20 14:27:47.240] [WARN] [nioEventLoopGroup-3-1] [single conn start]
[2024-12-20 14:27:47.241] [INFO] [nioEventLoopGroup-3-1] [accept]
[2024-12-20 14:27:48.235] [INFO] [DRC-Client-Thread] [Connect to http://172.16.20.200:17002/OB_MYSQL_CE_ten_1_6c85sicl4eps-1-0 successfully]
[2024-12-20 14:29:27.820] [INFO] [DRC-Client-Thread] [notify consume: 0.4444444444444444 ms]
[2024-12-20 14:30:55.161] [INFO] [DRC-Client-Thread] [notify consume: 0.3333333333333333 ms]
[2024-12-20 14:32:39.017] [INFO] [DRC-Client-Thread] [notify consume: 0.09090909090909091 ms]
[2024-12-20 14:33:50.449] [INFO] [DRC-Client-Thread] [notify consume: 0.6363636363636364 ms]
[2024-12-20 14:35:34.210] [INFO] [DRC-Client-Thread] [notify consume: 0.3076923076923077 ms]
[2024-12-20 14:37:02.681] [INFO] [DRC-Client-Thread] [notify consume: 0.3333333333333333 ms]
[2024-12-20 14:38:38.641] [INFO] [DRC-Client-Thread] [notify consume: 1.0 ms]
[2024-12-20 14:40:00.297] [INFO] [DRC-Client-Thread] [notify consume: 0.3333333333333333 ms]
[2024-12-20 14:41:34.593] [INFO] [DRC-Client-Thread] [notify consume: 0.5 ms]
[2024-12-20 14:42:45.739] [INFO] [DRC-Client-Thread] [notify consume: 0.3333333333333333 ms]
[2024-12-20 14:43:49.848] [INFO] [DRC-Client-Thread] [notify consume: 0.2857142857142857 ms]
[2024-12-20 14:45:25.590] [INFO] [DRC-Client-Thread] [notify consume: 0.5 ms]