com.alibaba.otter.canal.parse.exception.CanalParseException: java.io.IOException: connect main-db/172.224.0.6:3306 failure Caused by: java.io.IOException: connect main-db/172.224.0.6:3306 failure #25
Description
cd to /home/admin/canal-server/bin for workaround relative path
LOG CONFIGURATION : /home/admin/canal-server/bin/../conf/logback.xml
canal conf : /home/admin/canal-server/bin/../conf/canal_local.properties
CLASSPATH :/home/admin/canal-server/bin/../conf:/home/admin/canal-server/bin/../lib/zstd-jni-1.5.2-5.jar:/home/admin/canal-server/bin/../lib/zookeeper-jute-3.5.6.jar:/home/admin/canal-server/bin/../lib/zookeeper-3.5.6.jar:/home/admin/canal-server/bin/../lib/zkclient-0.10.jar:/home/admin/canal-server/bin/../lib/spring-tx-5.3.26.jar:/home/admin/canal-server/bin/../lib/spring-orm-5.3.26.jar:/home/admin/canal-server/bin/../lib/spring-jdbc-5.3.26.jar:/home/admin/canal-server/bin/../lib/spring-jcl-5.3.26.jar:/home/admin/canal-server/bin/../lib/spring-expression-5.3.26.jar:/home/admin/canal-server/bin/../lib/spring-core-5.3.26.jar:/home/admin/canal-server/bin/../lib/spring-context-5.3.26.jar:/home/admin/canal-server/bin/../lib/spring-beans-5.3.26.jar:/home/admin/canal-server/bin/../lib/spring-aop-5.3.26.jar:/home/admin/canal-server/bin/../lib/slf4j-api-1.7.12.jar:/home/admin/canal-server/bin/../lib/simpleclient_pushgateway-0.4.0.jar:/home/admin/canal-server/bin/../lib/simpleclient_httpserver-0.4.0.jar:/home/admin/canal-server/bin/../lib/simpleclient_hotspot-0.4.0.jar:/home/admin/canal-server/bin/../lib/simpleclient_common-0.4.0.jar:/home/admin/canal-server/bin/../lib/simpleclient-0.4.0.jar:/home/admin/canal-server/bin/../lib/protobuf-java-3.6.1.jar:/home/admin/canal-server/bin/../lib/polardbx-parser-5.4.19.jar:/home/admin/canal-server/bin/../lib/oro-2.0.8.jar:/home/admin/canal-server/bin/../lib/netty-all-4.1.68.Final.jar:/home/admin/canal-server/bin/../lib/netty-3.2.10.Final.jar:/home/admin/canal-server/bin/../lib/mysql-connector-java-5.1.48.jar:/home/admin/canal-server/bin/../lib/mybatis-spring-2.0.4.jar:/home/admin/canal-server/bin/../lib/mybatis-3.5.6.jar:/home/admin/canal-server/bin/../lib/logkit-1.0.1.jar:/home/admin/canal-server/bin/../lib/logback-core-1.2.9.jar:/home/admin/canal-server/bin/../lib/logback-classic-1.2.9.jar:/home/admin/canal-server/bin/../lib/log4j-1.2.12.jar:/home/admin/canal-server/bin/../lib/jsr305-3.0.2.jar:/home/admin/canal-server/bin/../lib/joda-time-2.9.4.jar:/home/admin/canal-server/bin/../lib/jctools-core-2.1.2.jar:/home/admin/canal-server/bin/../lib/jcl-over-slf4j-1.7.12.jar:/home/admin/canal-server/bin/../lib/javax.annotation-api-1.3.2.jar:/home/admin/canal-server/bin/../lib/j2objc-annotations-1.1.jar:/home/admin/canal-server/bin/../lib/httpcore-4.4.13.jar:/home/admin/canal-server/bin/../lib/httpclient-4.5.13.jar:/home/admin/canal-server/bin/../lib/h2-2.1.210.jar:/home/admin/canal-server/bin/../lib/guava-22.0.jar:/home/admin/canal-server/bin/../lib/fastjson2-2.0.31.jar:/home/admin/canal-server/bin/../lib/fastjson-1.2.69_noneautotype.jar:/home/admin/canal-server/bin/../lib/error_prone_annotations-2.0.18.jar:/home/admin/canal-server/bin/../lib/druid-1.2.21.jar:/home/admin/canal-server/bin/../lib/disruptor-3.4.2.jar:/home/admin/canal-server/bin/../lib/connector.core-1.1.8-SNAPSHOT.jar:/home/admin/canal-server/bin/../lib/commons-logging-1.2.jar:/home/admin/canal-server/bin/../lib/commons-lang3-3.7.jar:/home/admin/canal-server/bin/../lib/commons-lang-2.6.jar:/home/admin/canal-server/bin/../lib/commons-io-2.4.jar:/home/admin/canal-server/bin/../lib/commons-compress-1.22.jar:/home/admin/canal-server/bin/../lib/commons-collections-3.2.2.jar:/home/admin/canal-server/bin/../lib/commons-codec-1.9.jar:/home/admin/canal-server/bin/../lib/commons-beanutils-1.9.4.jar:/home/admin/canal-server/bin/../lib/canal.store-1.1.8-SNAPSHOT.jar:/home/admin/canal-server/bin/../lib/canal.sink-1.1.8-SNAPSHOT.jar:/home/admin/canal-server/bin/../lib/canal.server-1.1.8-SNAPSHOT.jar:/home/admin/canal-server/bin/../lib/canal.protocol-1.1.8-SNAPSHOT.jar:/home/admin/canal-server/bin/../lib/canal.prometheus-1.1.8-SNAPSHOT.jar:/home/admin/canal-server/bin/../lib/canal.parse.driver-1.1.8-SNAPSHOT.jar:/home/admin/canal-server/bin/../lib/canal.parse.dbsync-1.1.8-SNAPSHOT.jar:/home/admin/canal-server/bin/../lib/canal.parse-1.1.8-SNAPSHOT.jar:/home/admin/canal-server/bin/../lib/canal.meta-1.1.8-SNAPSHOT.jar:/home/admin/canal-server/bin/../lib/canal.instance.spring-1.1.8-SNAPSHOT.jar:/home/admin/canal-server/bin/../lib/canal.instance.manager-1.1.8-SNAPSHOT.jar:/home/admin/canal-server/bin/../lib/canal.instance.core-1.1.8-SNAPSHOT.jar:/home/admin/canal-server/bin/../lib/canal.filter-1.1.8-SNAPSHOT.jar:/home/admin/canal-server/bin/../lib/canal.deployer-1.1.8-SNAPSHOT.jar:/home/admin/canal-server/bin/../lib/canal.common-1.1.8-SNAPSHOT.jar:/home/admin/canal-server/bin/../lib/aviator-2.2.1.jar:/home/admin/canal-server/bin/../lib/avalon-framework-4.1.3.jar:/home/admin/canal-server/bin/../lib/audience-annotations-0.5.0.jar:/home/admin/canal-server/bin/../lib/animal-sniffer-annotations-1.14.jar:
10:58:53.719 [main] INFO c.a.o.canal.deployer.CanalLauncher - ## set default uncaught exception handler
10:58:53.721 [main] INFO c.a.o.canal.deployer.CanalLauncher - ## load canal configurations
10:58:54.121 [main] INFO c.a.o.c.c.core.spi.ExtensionLoader - extension classpath dir: /home/admin/canal-server/plugin
10:58:54.150 [main] INFO c.a.o.c.c.r.p.CanalRocketMQProducer - ##Start RocketMQ producer##
10:58:54.215 [main] INFO io.netty.channel.nio.NioEventLoop - instrumented a special java.util.Set into: sun.nio.ch.EPollSelectorImpl@324a0017
10:58:54.216 [main] INFO RocketmqRemoting - name server address updated. NEW : [192.168.88.123:9876] , OLD: null
10:58:54.216 [main] INFO RocketmqClient - user specified name server address: 192.168.88.123:9876
10:58:54.221 [main] INFO RocketmqClient - Created a new client Instance, InstanceIndex:0, ClientID:172.224.0.145@1#1734597116762499, ClientConfig:ClientConfig [namesrvAddr=192.168.88.123:9876, clientIP=172.224.0.145, instanceName=1#1734597116762499, clientCallbackExecutorThreads=8, pollNameServerInterval=30000, heartbeatBrokerInterval=30000, persistConsumerOffsetInterval=5000, pullTimeDelayMillsWhenException=1000, unitMode=false, unitName=null, vipChannelEnabled=false, useTLS=false, language=JAVA, namespace=null, mqClientApiTimeout=3000, enableStreamRequestType=false], ClientVersion:V4_9_8, SerializerType:JSON
10:58:54.221 [main] INFO RocketmqClient - Created new MQClientInstance for clientId:[172.224.0.145@1#1734597116762499]
10:58:54.227 [main] INFO RocketmqCommon - Try to start service thread:PullMessageService started:false lastThread:null
10:58:54.228 [main] INFO RocketmqCommon - Try to start service thread:RebalanceService started:false lastThread:null
10:58:54.228 [PullMessageService] INFO RocketmqClient - PullMessageService service started
10:58:54.228 [main] INFO RocketmqClient - the producer [CLIENT_INNER_PRODUCER] start OK. sendMessageWithVIPChannel=false
10:58:54.228 [RebalanceService] INFO RocketmqClient - RebalanceService service started
10:58:54.230 [main] INFO RocketmqClient - the client factory [172.224.0.145@1#1734597116762499] start OK
10:58:54.230 [main] INFO RocketmqClient - the producer [test] start OK. sendMessageWithVIPChannel=false
10:58:54.230 [main] INFO c.a.o.canal.deployer.CanalStarter - ## start the canal server.
10:58:54.238 [MQClientFactoryScheduledThread] INFO RocketmqRemoting - new name server is chosen. OLD: null , NEW: 192.168.88.123:9876. namesrvIndex = 750
10:58:54.284 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:zookeeper.version=3.5.6-c11b7e26bc554b8523dc929761dd28808913f091, built on 10/08/2019 20:18 GMT
10:58:54.284 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:host.name=e97e5bc3eac1
10:58:54.284 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.version=21.0.4
10:58:54.284 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.vendor=Eclipse Adoptium
10:58:54.284 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.home=/opt/java/openjdk
10:58:54.284 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.class.path=.:/home/admin/canal-server/bin/../conf:/home/admin/canal-server/bin/../lib/zstd-jni-1.5.2-5.jar:/home/admin/canal-server/bin/../lib/zookeeper-jute-3.5.6.jar:/home/admin/canal-server/bin/../lib/zookeeper-3.5.6.jar:/home/admin/canal-server/bin/../lib/zkclient-0.10.jar:/home/admin/canal-server/bin/../lib/spring-tx-5.3.26.jar:/home/admin/canal-server/bin/../lib/spring-orm-5.3.26.jar:/home/admin/canal-server/bin/../lib/spring-jdbc-5.3.26.jar:/home/admin/canal-server/bin/../lib/spring-jcl-5.3.26.jar:/home/admin/canal-server/bin/../lib/spring-expression-5.3.26.jar:/home/admin/canal-server/bin/../lib/spring-core-5.3.26.jar:/home/admin/canal-server/bin/../lib/spring-context-5.3.26.jar:/home/admin/canal-server/bin/../lib/spring-beans-5.3.26.jar:/home/admin/canal-server/bin/../lib/spring-aop-5.3.26.jar:/home/admin/canal-server/bin/../lib/slf4j-api-1.7.12.jar:/home/admin/canal-server/bin/../lib/simpleclient_pushgateway-0.4.0.jar:/home/admin/canal-server/bin/../lib/simpleclient_httpserver-0.4.0.jar:/home/admin/canal-server/bin/../lib/simpleclient_hotspot-0.4.0.jar:/home/admin/canal-server/bin/../lib/simpleclient_common-0.4.0.jar:/home/admin/canal-server/bin/../lib/simpleclient-0.4.0.jar:/home/admin/canal-server/bin/../lib/protobuf-java-3.6.1.jar:/home/admin/canal-server/bin/../lib/polardbx-parser-5.4.19.jar:/home/admin/canal-server/bin/../lib/oro-2.0.8.jar:/home/admin/canal-server/bin/../lib/netty-all-4.1.68.Final.jar:/home/admin/canal-server/bin/../lib/netty-3.2.10.Final.jar:/home/admin/canal-server/bin/../lib/mysql-connector-java-5.1.48.jar:/home/admin/canal-server/bin/../lib/mybatis-spring-2.0.4.jar:/home/admin/canal-server/bin/../lib/mybatis-3.5.6.jar:/home/admin/canal-server/bin/../lib/logkit-1.0.1.jar:/home/admin/canal-server/bin/../lib/logback-core-1.2.9.jar:/home/admin/canal-server/bin/../lib/logback-classic-1.2.9.jar:/home/admin/canal-server/bin/../lib/log4j-1.2.12.jar:/home/admin/canal-server/bin/../lib/jsr305-3.0.2.jar:/home/admin/canal-server/bin/../lib/joda-time-2.9.4.jar:/home/admin/canal-server/bin/../lib/jctools-core-2.1.2.jar:/home/admin/canal-server/bin/../lib/jcl-over-slf4j-1.7.12.jar:/home/admin/canal-server/bin/../lib/javax.annotation-api-1.3.2.jar:/home/admin/canal-server/bin/../lib/j2objc-annotations-1.1.jar:/home/admin/canal-server/bin/../lib/httpcore-4.4.13.jar:/home/admin/canal-server/bin/../lib/httpclient-4.5.13.jar:/home/admin/canal-server/bin/../lib/h2-2.1.210.jar:/home/admin/canal-server/bin/../lib/guava-22.0.jar:/home/admin/canal-server/bin/../lib/fastjson2-2.0.31.jar:/home/admin/canal-server/bin/../lib/fastjson-1.2.69_noneautotype.jar:/home/admin/canal-server/bin/../lib/error_prone_annotations-2.0.18.jar:/home/admin/canal-server/bin/../lib/druid-1.2.21.jar:/home/admin/canal-server/bin/../lib/disruptor-3.4.2.jar:/home/admin/canal-server/bin/../lib/connector.core-1.1.8-SNAPSHOT.jar:/home/admin/canal-server/bin/../lib/commons-logging-1.2.jar:/home/admin/canal-server/bin/../lib/commons-lang3-3.7.jar:/home/admin/canal-server/bin/../lib/commons-lang-2.6.jar:/home/admin/canal-server/bin/../lib/commons-io-2.4.jar:/home/admin/canal-server/bin/../lib/commons-compress-1.22.jar:/home/admin/canal-server/bin/../lib/commons-collections-3.2.2.jar:/home/admin/canal-server/bin/../lib/commons-codec-1.9.jar:/home/admin/canal-server/bin/../lib/commons-beanutils-1.9.4.jar:/home/admin/canal-server/bin/../lib/canal.store-1.1.8-SNAPSHOT.jar:/home/admin/canal-server/bin/../lib/canal.sink-1.1.8-SNAPSHOT.jar:/home/admin/canal-server/bin/../lib/canal.server-1.1.8-SNAPSHOT.jar:/home/admin/canal-server/bin/../lib/canal.protocol-1.1.8-SNAPSHOT.jar:/home/admin/canal-server/bin/../lib/canal.prometheus-1.1.8-SNAPSHOT.jar:/home/admin/canal-server/bin/../lib/canal.parse.driver-1.1.8-SNAPSHOT.jar:/home/admin/canal-server/bin/../lib/canal.parse.dbsync-1.1.8-SNAPSHOT.jar:/home/admin/canal-server/bin/../lib/canal.parse-1.1.8-SNAPSHOT.jar:/home/admin/canal-server/bin/../lib/canal.meta-1.1.8-SNAPSHOT.jar:/home/admin/canal-server/bin/../lib/canal.instance.spring-1.1.8-SNAPSHOT.jar:/home/admin/canal-server/bin/../lib/canal.instance.manager-1.1.8-SNAPSHOT.jar:/home/admin/canal-server/bin/../lib/canal.instance.core-1.1.8-SNAPSHOT.jar:/home/admin/canal-server/bin/../lib/canal.filter-1.1.8-SNAPSHOT.jar:/home/admin/canal-server/bin/../lib/canal.deployer-1.1.8-SNAPSHOT.jar:/home/admin/canal-server/bin/../lib/canal.common-1.1.8-SNAPSHOT.jar:/home/admin/canal-server/bin/../lib/aviator-2.2.1.jar:/home/admin/canal-server/bin/../lib/avalon-framework-4.1.3.jar:/home/admin/canal-server/bin/../lib/audience-annotations-0.5.0.jar:/home/admin/canal-server/bin/../lib/animal-sniffer-annotations-1.14.jar:
10:58:54.284 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.library.path=/usr/java/packages/lib:/usr/lib64:/lib64:/lib:/usr/lib
10:58:54.284 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.io.tmpdir=/tmp
10:58:54.284 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.compiler=<NA>
10:58:54.284 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:os.name=Linux
10:58:54.284 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:os.arch=amd64
10:58:54.284 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:os.version=6.1.0-25-amd64
10:58:54.284 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:user.name=admin
10:58:54.284 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:user.home=/home/admin
10:58:54.284 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:user.dir=/home/admin/canal-server/bin
10:58:54.284 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:os.memory.free=1991MB
10:58:54.284 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:os.memory.max=3072MB
10:58:54.284 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:os.memory.total=2050MB
10:58:54.285 [main] INFO org.apache.zookeeper.ZooKeeper - Initiating client connection, connectString=zoo1:2181,zoo2:2181,zoo3:2181 sessionTimeout=90000 watcher=com.alibaba.otter.canal.common.zookeeper.ZkClientx@163d04ff
10:58:54.286 [main] INFO org.apache.zookeeper.common.X509Util - Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation
10:58:54.286 [ZkClient-EventThread-28-zoo1:2181,zoo2:2181,zoo3:2181] INFO org.I0Itec.zkclient.ZkEventThread - Starting ZkClient event thread.
10:58:54.288 [main] INFO o.apache.zookeeper.ClientCnxnSocket - jute.maxbuffer value is 4194304 Bytes
10:58:54.290 [main] INFO org.apache.zookeeper.ClientCnxn - zookeeper.request.timeout value is 0. feature enabled=
10:58:54.292 [main] INFO org.I0Itec.zkclient.ZkClient - Waiting for keeper state SyncConnected
10:58:54.294 [MQClientFactoryScheduledThread] INFO RocketmqRemoting - createChannel: begin to connect remote host[192.168.88.123:9876] asynchronously
10:58:54.295 [main-SendThread(zoo1:2181)] INFO org.apache.zookeeper.ClientCnxn - Opening socket connection to server zoo1/172.224.0.11:2181. Will not attempt to authenticate using SASL (unknown error)
10:58:54.297 [main-SendThread(zoo1:2181)] INFO org.apache.zookeeper.ClientCnxn - Socket connection established, initiating session, client: /172.224.0.145:53052, server: zoo1/172.224.0.11:2181
10:58:54.307 [NettyClientWorkerThread_1] INFO RocketmqRemoting - NETTY CLIENT PIPELINE: CONNECT UNKNOWN => 192.168.88.123:9876
10:58:54.309 [MQClientFactoryScheduledThread] INFO RocketmqRemoting - createChannel: connect remote host[192.168.88.123:9876] success, AbstractBootstrap$PendingRegistrationPromise@6a99adaf(success)
10:58:54.330 [main-SendThread(zoo1:2181)] INFO org.apache.zookeeper.ClientCnxn - Session establishment complete on server zoo1/172.224.0.11:2181, sessionid = 0x100676345cb0000, negotiated timeout = 40000
10:58:54.332 [main-EventThread] INFO org.I0Itec.zkclient.ZkClient - zookeeper state changed (SyncConnected)
10:58:54.364 [main] INFO c.a.o.canal.deployer.CanalController - ## start the canal server[172.224.0.145(172.224.0.145):11111]
10:58:54.381 [main] INFO c.a.o.c.prometheus.PrometheusService - Start prometheus HTTPServer on port 11112.
10:58:54.455 [MQClientFactoryScheduledThread] INFO RocketmqClient - the topic[TBW102] route info changed, old[null] ,new[TopicRouteData [orderTopicConf=null, queueDatas=[QueueData [brokerName=q1, readQueueNums=8, writeQueueNums=8, perm=7, topicSysFlag=0], QueueData [brokerName=q3, readQueueNums=8, writeQueueNums=8, perm=7, topicSysFlag=0]], brokerDatas=[BrokerData [brokerName=q1, brokerAddrs={0=192.168.88.123:11911, 1=192.168.88.123:12911}], BrokerData [brokerName=q3, brokerAddrs={0=192.168.88.123:13911, 1=192.168.88.123:14911}]], filterServerTable={}]]
10:58:54.455 [MQClientFactoryScheduledThread] INFO RocketmqClient - updateTopicPublishInfo prev is not null, TopicPublishInfo [orderTopic=false, messageQueueList=[], sendWhichQueue=ThreadLocalIndex{threadLocalIndex=null}, haveTopicRouterInfo=false]
10:58:54.456 [MQClientFactoryScheduledThread] INFO RocketmqClient - updateTopicPublishInfo prev is not null, TopicPublishInfo [orderTopic=false, messageQueueList=[], sendWhichQueue=ThreadLocalIndex{threadLocalIndex=null}, haveTopicRouterInfo=false]
10:58:54.456 [MQClientFactoryScheduledThread] INFO RocketmqClient - topicRouteTable.put. Topic = TBW102, TopicRouteData[TopicRouteData [orderTopicConf=null, queueDatas=[QueueData [brokerName=q1, readQueueNums=8, writeQueueNums=8, perm=7, topicSysFlag=0], QueueData [brokerName=q3, readQueueNums=8, writeQueueNums=8, perm=7, topicSysFlag=0]], brokerDatas=[BrokerData [brokerName=q1, brokerAddrs={0=192.168.88.123:11911, 1=192.168.88.123:12911}], BrokerData [brokerName=q3, brokerAddrs={0=192.168.88.123:13911, 1=192.168.88.123:14911}]], filterServerTable={}]]
10:58:54.473 [main] INFO c.a.o.canal.deployer.CanalStarter - ## the canal server is running now ......
10:58:54.475 [main] INFO c.a.o.canal.server.CanalMQStarter - ## start the MQ workers.
10:58:54.475 [main] INFO c.a.o.canal.server.CanalMQStarter - ## the MQ workers is running now ......
10:58:55.028 [canal-instance-scan-0] INFO c.a.o.c.p.CanalInstanceExports - Successfully register metrics for instance test.
10:58:55.029 [canal-instance-scan-0] INFO c.a.o.c.prometheus.PrometheusService - Register metrics for destination test.
10:58:55.029 [canal-instance-scan-0] INFO c.a.o.c.i.s.CanalInstanceWithSpring - start CannalInstance for 1-test
10:58:55.132 [New I/O server boss #1 ([id: 0x7997b197, /0.0.0.0:11110])] INFO c.a.o.c.a.h.HandshakeInitializationHandler - send handshake initialization packet to : [id: 0x65f4dbe3, /172.224.0.7:52726 => /172.224.0.145:11110]
10:58:55.136 [New I/O server worker #1-1] INFO c.a.o.c.a.h.HandshakeInitializationHandler - remove unused channel handlers after authentication is done successfully.
10:58:55.148 [New I/O server worker #1-1] INFO c.a.o.c.a.h.ClientAuthenticationHandler - remove unused channel handlers after authentication is done successfully.
10:58:55.193 [New I/O server worker #1-1] INFO c.a.o.c.admin.handler.SessionHandler - message receives in session handler...
10:58:55.240 [MQClientFactoryScheduledThread] INFO RocketmqRemoting - createChannel: begin to connect remote host[192.168.88.123:11911] asynchronously
10:58:55.244 [NettyClientWorkerThread_2] INFO RocketmqRemoting - NETTY CLIENT PIPELINE: CONNECT UNKNOWN => 192.168.88.123:11911
10:58:55.246 [MQClientFactoryScheduledThread] INFO RocketmqRemoting - createChannel: connect remote host[192.168.88.123:11911] success, AbstractBootstrap$PendingRegistrationPromise@804ae52(success)
10:58:55.257 [MQClientFactoryScheduledThread] INFO RocketmqClient - send heart beat to broker[q1 0 192.168.88.123:11911] success
10:58:55.257 [MQClientFactoryScheduledThread] INFO RocketmqClient - HeartbeatData [clientID=172.224.0.145@1#1734597116762499, producerDataSet=[ProducerData [groupName=CLIENT_INNER_PRODUCER], ProducerData [groupName=test]], consumerDataSet=[]]
10:58:55.258 [MQClientFactoryScheduledThread] INFO RocketmqRemoting - createChannel: begin to connect remote host[192.168.88.123:13911] asynchronously
10:58:55.306 [NettyClientWorkerThread_3] INFO RocketmqRemoting - NETTY CLIENT PIPELINE: CONNECT UNKNOWN => 192.168.88.123:13911
10:58:55.311 [MQClientFactoryScheduledThread] INFO RocketmqRemoting - createChannel: connect remote host[192.168.88.123:13911] success, AbstractBootstrap$PendingRegistrationPromise@20cfc6c8(success)
10:58:55.321 [MQClientFactoryScheduledThread] INFO RocketmqClient - send heart beat to broker[q3 0 192.168.88.123:13911] success
10:58:55.321 [MQClientFactoryScheduledThread] INFO RocketmqClient - HeartbeatData [clientID=172.224.0.145@1#1734597116762499, producerDataSet=[ProducerData [groupName=CLIENT_INNER_PRODUCER], ProducerData [groupName=test]], consumerDataSet=[]]
10:58:55.624 [canal-instance-scan-0] INFO c.alibaba.druid.pool.DruidDataSource - {dataSource-1} inited
10:58:55.801 [canal-instance-scan-0] INFO c.a.o.c.p.i.m.t.DefaultTableMetaTSDBFactory - test init TableMetaTSDB with classpath:spring/tsdb/mysql-tsdb.xml
10:58:55.807 [canal-instance-scan-0] WARN c.a.o.c.p.i.m.dbsync.LogEventConvert - --> init table filter : ^.*\..*$
10:58:55.807 [canal-instance-scan-0] WARN c.a.o.c.p.i.m.dbsync.LogEventConvert - --> init table black filter :
10:58:55.811 [canal-instance-scan-0] INFO c.a.o.c.i.core.AbstractCanalInstance - start successful....
10:58:55.811 [canal-instance-scan-0] INFO c.a.o.c.s.e.CanalServerWithEmbedded - start CanalInstances[test] successfully
10:58:55.811 [destination = test , address = main-db/172.224.0.6:3306 , EventParser] INFO c.a.o.c.p.i.m.r.RdsBinlogEventParserProxy - start heart beat....
10:58:55.812 [canal-instance-scan-0] INFO c.a.o.canal.server.CanalMQStarter - ## Start the MQ work of destination:test
10:58:55.812 [destination = test , address = main-db/172.224.0.6:3306 , EventParser] INFO c.a.o.c.p.d.mysql.MysqlConnector - connect MysqlConnection to main-db/172.224.0.6:3306...
10:58:55.812 [canal-instance-scan-0] INFO c.a.o.canal.deployer.CanalController - auto notify start test successful.
10:58:55.813 [pool-2-thread-1] INFO c.a.o.canal.server.CanalMQStarter - ## start the MQ producer: test.
10:58:55.814 [destination = test , address = main-db/172.224.0.6:3306 , EventParser] INFO c.a.o.c.p.d.mysql.MysqlConnector - handshake initialization packet received, prepare the client authentication packet to send
10:58:55.815 [destination = test , address = main-db/172.224.0.6:3306 , EventParser] INFO c.a.o.c.p.d.mysql.MysqlConnector - auth plugin: caching_sha2_password
10:58:55.816 [destination = test , address = main-db/172.224.0.6:3306 , EventParser] INFO c.a.o.c.p.d.mysql.MysqlConnector - client authentication packet is sent out.
10:58:55.817 [destination = test , address = main-db/172.224.0.6:3306 , EventParser] INFO c.a.o.c.p.d.mysql.MysqlConnector - auth switch response packet is sent out.
10:58:55.818 [destination = test , address = main-db/172.224.0.6:3306 , EventParser] INFO c.a.o.c.p.d.mysql.MysqlConnector - disConnect MysqlConnection to main-db/172.224.0.6:3306...
10:58:55.822 [destination = test , address = main-db/172.224.0.6:3306 , EventParser] ERROR c.a.o.c.p.i.m.r.RdsBinlogEventParserProxy - dump address main-db/172.224.0.6:3306 has an error, retrying. caused by
com.alibaba.otter.canal.parse.exception.CanalParseException: java.io.IOException: connect main-db/172.224.0.6:3306 failure
Caused by: java.io.IOException: connect main-db/172.224.0.6:3306 failure
at com.alibaba.otter.canal.parse.driver.mysql.MysqlConnector.connect(MysqlConnector.java:85)
at com.alibaba.otter.canal.parse.inbound.mysql.MysqlConnection.connect(MysqlConnection.java:104)
at com.alibaba.otter.canal.parse.inbound.mysql.MysqlEventParser.preDump(MysqlEventParser.java:89)
at com.alibaba.otter.canal.parse.inbound.AbstractEventParser$1.run(AbstractEventParser.java:171)
at java.base/java.lang.Thread.run(Thread.java:1583)
Caused by: java.io.IOException: Error When doing Client Authentication:ErrorPacket [errorNumber=1045, fieldCount=-1, message=Access denied for user 'canal'@'172.224.0.145' (using password: YES), sqlState=28000, sqlStateMarker=#]
at com.alibaba.otter.canal.parse.driver.mysql.MysqlConnector.negotiate(MysqlConnector.java:325)
at com.alibaba.otter.canal.parse.driver.mysql.MysqlConnector.connect(MysqlConnector.java:81)
... 4 common frames omitted
10:58:55.824 [destination = test , address = main-db/172.224.0.6:3306 , EventParser] ERROR c.a.o.c.common.alarm.LogAlarmHandler - destination:test[com.alibaba.otter.canal.parse.exception.CanalParseException: java.io.IOException: connect main-db/172.224.0.6:3306 failure
Caused by: java.io.IOException: connect main-db/172.224.0.6:3306 failure
at com.alibaba.otter.canal.parse.driver.mysql.MysqlConnector.connect(MysqlConnector.java:85)
at com.alibaba.otter.canal.parse.inbound.mysql.MysqlConnection.connect(MysqlConnection.java:104)
at com.alibaba.otter.canal.parse.inbound.mysql.MysqlEventParser.preDump(MysqlEventParser.java:89)
at com.alibaba.otter.canal.parse.inbound.AbstractEventParser$1.run(AbstractEventParser.java:171)
at java.base/java.lang.Thread.run(Thread.java:1583)
Caused by: java.io.IOException: Error When doing Client Authentication:ErrorPacket [errorNumber=1045, fieldCount=-1, message=Access denied for user 'canal'@'172.224.0.145' (using password: YES), sqlState=28000, sqlStateMarker=#]
at com.alibaba.otter.canal.parse.driver.mysql.MysqlConnector.negotiate(MysqlConnector.java:325)
at com.alibaba.otter.canal.parse.driver.mysql.MysqlConnector.connect(MysqlConnector.java:81)
... 4 more
]
10:58:55.824 [destination = test , address = main-db/172.224.0.6:3306 , EventParser] INFO c.a.o.c.p.d.mysql.MysqlConnector - the channel main-db/172.224.0.6:3306 is not connected
10:58:55.824 [destination = test , address = main-db/172.224.0.6:3306 , EventParser] INFO c.a.o.c.p.d.mysql.MysqlConnector - the channel main-db/172.224.0.6:3306 is not connected
10:58:55.815 [pool-2-thread-1] INFO c.a.o.c.s.e.CanalServerWithEmbedded - subscribe successfully, ClientIdentity[destination=test,clientId=1001,filter=] with first position:null
10:58:55.838 [pool-2-thread-1] INFO c.a.o.canal.server.CanalMQStarter - ## the MQ producer: test is running now ......
10:59:06.989 [destination = test , address = main-db/172.224.0.6:3306 , EventParser] INFO c.a.o.c.p.d.mysql.MysqlConnector - connect MysqlConnection to main-db/172.224.0.6:3306...
10:59:06.989 [destination = test , address = main-db/172.224.0.6:3306 , EventParser] INFO c.a.o.c.p.d.mysql.MysqlConnector - handshake initialization packet received, prepare the client authentication packet to send
10:59:06.989 [destination = test , address = main-db/172.224.0.6:3306 , EventParser] INFO c.a.o.c.p.d.mysql.MysqlConnector - auth plugin: caching_sha2_password
10:59:06.989 [destination = test , address = main-db/172.224.0.6:3306 , EventParser] INFO c.a.o.c.p.d.mysql.MysqlConnector - client authentication packet is sent out.
10:59:06.989 [destination = test , address = main-db/172.224.0.6:3306 , EventParser] INFO c.a.o.c.p.d.mysql.MysqlConnector - auth switch response packet is sent out.
10:59:06.989 [destination = test , address = main-db/172.224.0.6:3306 , EventParser] INFO c.a.o.c.p.d.mysql.MysqlConnector - disConnect MysqlConnection to main-db/172.224.0.6:3306...
10:59:06.989 [destination = test , address = main-db/172.224.0.6:3306 , EventParser] ERROR c.a.o.c.p.i.m.r.RdsBinlogEventParserProxy - dump address main-db/172.224.0.6:3306 has an error, retrying. caused by
com.alibaba.otter.canal.parse.exception.CanalParseException: java.io.IOException: connect main-db/172.224.0.6:3306 failure
Caused by: java.io.IOException: connect main-db/172.224.0.6:3306 failure
at com.alibaba.otter.canal.parse.driver.mysql.MysqlConnector.connect(MysqlConnector.java:85)
at com.alibaba.otter.canal.parse.inbound.mysql.MysqlConnection.connect(MysqlConnection.java:104)
at com.alibaba.otter.canal.parse.inbound.mysql.MysqlEventParser.preDump(MysqlEventParser.java:89)
at com.alibaba.otter.canal.parse.inbound.AbstractEventParser$1.run(AbstractEventParser.java:171)
at java.base/java.lang.Thread.run(Thread.java:1583)
Caused by: java.io.IOException: Error When doing Client Authentication:ErrorPacket [errorNumber=1045, fieldCount=-1, message=Access denied for user 'canal'@'172.224.0.145' (using password: YES), sqlState=28000, sqlStateMarker=#]
at com.alibaba.otter.canal.parse.driver.mysql.MysqlConnector.negotiate(MysqlConnector.java:325)
at com.alibaba.otter.canal.parse.driver.mysql.MysqlConnector.connect(MysqlConnector.java:81)
... 4 common frames omitted
10:59:06.990 [destination = test , address = main-db/172.224.0.6:3306 , EventParser] ERROR c.a.o.c.common.alarm.LogAlarmHandler - destination:test[com.alibaba.otter.canal.parse.exception.CanalParseException: java.io.IOException: connect main-db/172.224.0.6:3306 failure
Caused by: java.io.IOException: connect main-db/172.224.0.6:3306 failure
at com.alibaba.otter.canal.parse.driver.mysql.MysqlConnector.connect(MysqlConnector.java:85)
at com.alibaba.otter.canal.parse.inbound.mysql.MysqlConnection.connect(MysqlConnection.java:104)
at com.alibaba.otter.canal.parse.inbound.mysql.MysqlEventParser.preDump(MysqlEventParser.java:89)
at com.alibaba.otter.canal.parse.inbound.AbstractEventParser$1.run(AbstractEventParser.java:171)
at java.base/java.lang.Thread.run(Thread.java:1583)
Caused by: java.io.IOException: Error When doing Client Authentication:ErrorPacket [errorNumber=1045, fieldCount=-1, message=Access denied for user 'canal'@'172.224.0.145' (using password: YES), sqlState=28000, sqlStateMarker=#]
at com.alibaba.otter.canal.parse.driver.mysql.MysqlConnector.negotiate(MysqlConnector.java:325)
at com.alibaba.otter.canal.parse.driver.mysql.MysqlConnector.connect(MysqlConnector.java:81)
... 4 more
]
10:59:06.990 [destination = test , address = main-db/172.224.0.6:3306 , EventParser] INFO c.a.o.c.p.d.mysql.MysqlConnector - the channel main-db/172.224.0.6:3306 is not connected
10:59:06.990 [destination = test , address = main-db/172.224.0.6:3306 , EventParser] INFO c.a.o.c.p.d.mysql.MysqlConnector - the channel main-db/172.224.0.6:3306 is not connected
10:59:16.991 [destination = test , address = main-db/172.224.0.6:3306 , EventParser] INFO c.a.o.c.p.d.mysql.MysqlConnector - connect MysqlConnection to main-db/172.224.0.6:3306...
10:59:16.991 [destination = test , address = main-db/172.224.0.6:3306 , EventParser] INFO c.a.o.c.p.d.mysql.MysqlConnector - handshake initialization packet received, prepare the client authentication packet to send
10:59:16.991 [destination = test , address = main-db/172.224.0.6:3306 , EventParser] INFO c.a.o.c.p.d.mysql.MysqlConnector - auth plugin: caching_sha2_password
10:59:16.992 [destination = test , address = main-db/172.224.0.6:3306 , EventParser] INFO c.a.o.c.p.d.mysql.MysqlConnector - client authentication packet is sent out.
10:59:16.992 [destination = test , address = main-db/172.224.0.6:3306 , EventParser] INFO c.a.o.c.p.d.mysql.MysqlConnector - auth switch response packet is sent out.
10:59:16.992 [destination = test , address = main-db/172.224.0.6:3306 , EventParser] INFO c.a.o.c.p.d.mysql.MysqlConnector - disConnect MysqlConnection to main-db/172.224.0.6:3306...
10:59:16.992 [destination = test , address = main-db/172.224.0.6:3306 , EventParser] ERROR c.a.o.c.p.i.m.r.RdsBinlogEventParserProxy - dump address main-db/172.224.0.6:3306 has an error, retrying. caused by
com.alibaba.otter.canal.parse.exception.CanalParseException: java.io.IOException: connect main-db/172.224.0.6:3306 failure
Caused by: java.io.IOException: connect main-db/172.224.0.6:3306 failure
at com.alibaba.otter.canal.parse.driver.mysql.MysqlConnector.connect(MysqlConnector.java:85)
at com.alibaba.otter.canal.parse.inbound.mysql.MysqlConnection.connect(MysqlConnection.java:104)
at com.alibaba.otter.canal.parse.inbound.mysql.MysqlEventParser.preDump(MysqlEventParser.java:89)
at com.alibaba.otter.canal.parse.inbound.AbstractEventParser$1.run(AbstractEventParser.java:171)
at java.base/java.lang.Thread.run(Thread.java:1583)
Caused by: java.io.IOException: Error When doing Client Authentication:ErrorPacket [errorNumber=1045, fieldCount=-1, message=Access denied for user 'canal'@'172.224.0.145' (using password: YES), sqlState=28000, sqlStateMarker=#]
at com.alibaba.otter.canal.parse.driver.mysql.MysqlConnector.negotiate(MysqlConnector.java:325)
at com.alibaba.otter.canal.parse.driver.mysql.MysqlConnector.connect(MysqlConnector.java:81)
... 4 common frames omitted
10:59:16.992 [destination = test , address = main-db/172.224.0.6:3306 , EventParser] ERROR c.a.o.c.common.alarm.LogAlarmHandler - destination:test[com.alibaba.otter.canal.parse.exception.CanalParseException: java.io.IOException: connect main-db/172.224.0.6:3306 failure
Caused by: java.io.IOException: connect main-db/172.224.0.6:3306 failure
at com.alibaba.otter.canal.parse.driver.mysql.MysqlConnector.connect(MysqlConnector.java:85)
at com.alibaba.otter.canal.parse.inbound.mysql.MysqlConnection.connect(MysqlConnection.java:104)
at com.alibaba.otter.canal.parse.inbound.mysql.MysqlEventParser.preDump(MysqlEventParser.java:89)
at com.alibaba.otter.canal.parse.inbound.AbstractEventParser$1.run(AbstractEventParser.java:171)
at java.base/java.lang.Thread.run(Thread.java:1583)
Caused by: java.io.IOException: Error When doing Client Authentication:ErrorPacket [errorNumber=1045, fieldCount=-1, message=Access denied for user 'canal'@'172.224.0.145' (using password: YES), sqlState=28000, sqlStateMarker=#]
at com.alibaba.otter.canal.parse.driver.mysql.MysqlConnector.negotiate(MysqlConnector.java:325)
at com.alibaba.otter.canal.parse.driver.mysql.MysqlConnector.connect(MysqlConnector.java:81)
... 4 more
]
10:59:16.992 [destination = test , address = main-db/172.224.0.6:3306 , EventParser] INFO c.a.o.c.p.d.mysql.MysqlConnector - the channel main-db/172.224.0.6:3306 is not connected
10:59:16.992 [destination = test , address = main-db/172.224.0.6:3306 , EventParser] INFO c.a.o.c.p.d.mysql.MysqlConnector - the channel main-db/172.224.0.6:3306 is not connected
10:59:33.275 [destination = test , address = main-db/172.224.0.6:3306 , EventParser] INFO c.a.o.c.p.d.mysql.MysqlConnector - connect MysqlConnection to main-db/172.224.0.6:3306...
10:59:33.275 [destination = test , address = main-db/172.224.0.6:3306 , EventParser] INFO c.a.o.c.p.d.mysql.MysqlConnector - handshake initialization packet received, prepare the client authentication packet to send
10:59:33.275 [destination = test , address = main-db/172.224.0.6:3306 , EventParser] INFO c.a.o.c.p.d.mysql.MysqlConnector - auth plugin: caching_sha2_password
10:59:33.275 [destination = test , address = main-db/172.224.0.6:3306 , EventParser] INFO c.a.o.c.p.d.mysql.MysqlConnector - client authentication packet is sent out.
10:59:33.275 [destination = test , address = main-db/172.224.0.6:3306 , EventParser] INFO c.a.o.c.p.d.mysql.MysqlConnector - auth switch response packet is sent out.
10:59:33.276 [destination = test , address = main-db/172.224.0.6:3306 , EventParser] INFO c.a.o.c.p.d.mysql.MysqlConnector - disConnect MysqlConnection to main-db/172.224.0.6:3306...
10:59:33.276 [destination = test , address = main-db/172.224.0.6:3306 , EventParser] ERROR c.a.o.c.p.i.m.r.RdsBinlogEventParserProxy - dump address main-db/172.224.0.6:3306 has an error, retrying. caused by
com.alibaba.otter.canal.parse.exception.CanalParseException: java.io.IOException: connect main-db/172.224.0.6:3306 failure
Caused by: java.io.IOException: connect main-db/172.224.0.6:3306 failure
at com.alibaba.otter.canal.parse.driver.mysql.MysqlConnector.connect(MysqlConnector.java:85)
at com.alibaba.otter.canal.parse.inbound.mysql.MysqlConnection.connect(MysqlConnection.java:104)
at com.alibaba.otter.canal.parse.inbound.mysql.MysqlEventParser.preDump(MysqlEventParser.java:89)
at com.alibaba.otter.canal.parse.inbound.AbstractEventParser$1.run(AbstractEventParser.java:171)
at java.base/java.lang.Thread.run(Thread.java:1583)
Caused by: java.io.IOException: Error When doing Client Authentication:ErrorPacket [errorNumber=1045, fieldCount=-1, message=Access denied for user 'canal'@'172.224.0.145' (using password: YES), sqlState=28000, sqlStateMarker=#]
at com.alibaba.otter.canal.parse.driver.mysql.MysqlConnector.negotiate(MysqlConnector.java:325)
at com.alibaba.otter.canal.parse.driver.mysql.MysqlConnector.connect(MysqlConnector.java:81)
... 4 common frames omitted
10:59:33.276 [destination = test , address = main-db/172.224.0.6:3306 , EventParser] ERROR c.a.o.c.common.alarm.LogAlarmHandler - destination:test[com.alibaba.otter.canal.parse.exception.CanalParseException: java.io.IOException: connect main-db/172.224.0.6:3306 failure
Caused by: java.io.IOException: connect main-db/172.224.0.6:3306 failure
at com.alibaba.otter.canal.parse.driver.mysql.MysqlConnector.connect(MysqlConnector.java:85)
at com.alibaba.otter.canal.parse.inbound.mysql.MysqlConnection.connect(MysqlConnection.java:104)
at com.alibaba.otter.canal.parse.inbound.mysql.MysqlEventParser.preDump(MysqlEventParser.java:89)
at com.alibaba.otter.canal.parse.inbound.AbstractEventParser$1.run(AbstractEventParser.java:171)
at java.base/java.lang.Thread.run(Thread.java:1583)
Caused by: java.io.IOException: Error When doing Client Authentication:ErrorPacket [errorNumber=1045, fieldCount=-1, message=Access denied for user 'canal'@'172.224.0.145' (using password: YES), sqlState=28000, sqlStateMarker=#]
at com.alibaba.otter.canal.parse.driver.mysql.MysqlConnector.negotiate(MysqlConnector.java:325)
at com.alibaba.otter.canal.parse.driver.mysql.MysqlConnector.connect(MysqlConnector.java:81)
... 4 more
]
10:59:33.276 [destination = test , address = main-db/172.224.0.6:3306 , EventParser] INFO c.a.o.c.p.d.mysql.MysqlConnector - the channel main-db/172.224.0.6:3306 is not connected
10:59:33.276 [destination = test , address = main-db/172.224.0.6:3306 , EventParser] INFO c.a.o.c.p.d.mysql.MysqlConnector - the channel main-db/172.224.0.6:3306 is not connected