FvvSuu opened a new issue, #6423:
URL: https://github.com/apache/inlong/issues/6423
### What happened
Consumer registration failed due to BDB error
### What you expected to happen
client log:
2022-11-04 19:40:39.746 - WARN [ main]
.a.i.t.c.c.BaseMessageConsumer:631 [Register Failed] Requested topic
[[test_topic_0]] not deployed!
2022-11-04 19:40:39.747 - WARN [ main]
.a.i.t.c.c.BaseMessageConsumer:631 [Register Failed] Requested topic
[[test_topic_0]] not deployed!
2022-11-04 19:40:39.748 - WARN [ main]
.a.i.t.c.c.BaseMessageConsumer:631 [Register Failed] Requested topic
[[test_topic_0]] not deployed!
2022-11-04 19:40:39.748 -ERROR [ main]
.a.i.t.c.c.BaseMessageConsumer:642 Register to master failed! please check and
retry later.
org.apache.inlong.tubemq.client.exception.TubeClientException: Register to
master failed! please check and retry later.
at
org.apache.inlong.tubemq.client.consumer.BaseMessageConsumer.startMasterAndBrokerThreads(BaseMessageConsumer.java:644)
at
org.apache.inlong.tubemq.client.consumer.BaseMessageConsumer.completeSubscribe(BaseMessageConsumer.java:301)
at
org.apache.inlong.tubemq.client.consumer.SimplePullMessageConsumer.completeSubscribe(SimplePullMessageConsumer.java:117)
at
org.apache.inlong.tubemq.server.tools.cli.CliConsumer.initTask(CliConsumer.java:261)
at
org.apache.inlong.tubemq.server.tools.cli.CliConsumer.main(CliConsumer.java:384)
2022-11-04 19:40:39.748 -ERROR [ main] o.a.i.t.s.t.c.CliConsumer
:411 Register to master failed! please check and retry later.
master log:
[INFO] 2022-11-04 19:18:08,042 [DefaultMetaDataService] [Meta data] trigger
broker syncStatus info, brokerId=195060258
[INFO] 2022-11-04 19:18:22,584 [DefBrokerRunManager] [Broker Release]
brokerId=195060258, isTimeout=false, release success!
[INFO] 2022-11-04 19:18:22,584 [DefBrokerRunManager] [Broker Closed]
brokerId=195060258 unregister success, isOverTLS=false
[INFO] 2022-11-04 19:18:36,686 [CmptTMaster] [Balance Status] 4,
isMaster=true, isPrimaryNodeActive=false
[ERROR] 2022-11-04 19:18:46,381 [BdbMetaConfigMapperImpl] [MetaConfig
Error] Connect to
node:[test-tube-master-1,TubeMQMasterGroupNode-test-tube-master-1] IOException
error is java.net.ConnectException: Connection refused
[ERROR] 2022-11-04 19:18:56,388 [BdbMetaConfigMapperImpl] [MetaConfig
Error] Connect to
node:[test-tube-master-1,TubeMQMasterGroupNode-test-tube-master-1] IOException
error
java.net.ConnectException: Connection refused
at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
at
sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:716)
at sun.nio.ch.SocketAdaptor.connect(SocketAdaptor.java:122)
at
com.sleepycat.je.rep.utilint.RepUtils.openSocketChannel(RepUtils.java:467)
at
com.sleepycat.je.rep.utilint.net.SimpleChannelFactory.connect(SimpleChannelFactory.java:52)
at com.sleepycat.je.rep.util.DbPing.getNodeState(DbPing.java:309)
at
com.sleepycat.je.rep.util.ReplicationGroupAdmin.getNodeState(ReplicationGroupAdmin.java:430)
at
com.tencent.tubemq.server.master.metamanage.metastore.impl.bdbimpl.BdbMetaConfigMapperImpl.getMasterGroupStatus(BdbMetaConfigMapperImpl.java:334)
at
com.tencent.tubemq.server.master.metamanage.DefaultMetaDataService$2.run(DefaultMetaDataService.java:111)
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
[ERROR] 2022-11-04 19:19:06,381 [BdbMetaConfigMapperImpl] [MetaConfig
Error] Connect to
node:[test-tube-master-1,TubeMQMasterGroupNode-test-tube-master-1] IOException
error
java.net.ConnectException: Connection refused
at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
at
sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:716)
at sun.nio.ch.SocketAdaptor.connect(SocketAdaptor.java:122)
at
com.sleepycat.je.rep.utilint.RepUtils.openSocketChannel(RepUtils.java:467)
at
com.sleepycat.je.rep.utilint.net.SimpleChannelFactory.connect(SimpleChannelFactory.java:52)
at com.sleepycat.je.rep.util.DbPing.getNodeState(DbPing.java:309)
at
com.sleepycat.je.rep.util.ReplicationGroupAdmin.getNodeState(ReplicationGroupAdmin.java:430)
at
com.tencent.tubemq.server.master.metamanage.metastore.impl.bdbimpl.BdbMetaConfigMapperImpl.getMasterGroupStatus(BdbMetaConfigMapperImpl.java:334)
at
com.tencent.tubemq.server.master.metamanage.DefaultMetaDataService$2.run(DefaultMetaDataService.java:111)
### How to reproduce
Update to the latest version without clearing metadata
### Environment
_No response_
### InLong version
master
### InLong Component
InLong TubeMQ
### Are you willing to submit PR?
- [ ] Yes, I am willing to submit a PR!
### Code of Conduct
- [X] I agree to follow this project's [Code of
Conduct](https://www.apache.org/foundation/policies/conduct)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
