You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@inlong.apache.org by GitBox <gi...@apache.org> on 2022/11/07 05:35:02 UTC
[GitHub] [inlong] FvvSuu opened a new issue, #6423: [Bug][TubeMQ] Consumer registration failed due to BDB error
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: dev-unsubscribe@inlong.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [inlong] gosonzhang closed issue #6423: [Bug][TubeMQ] Consumer registration failed due to BDB error
Posted by GitBox <gi...@apache.org>.
gosonzhang closed issue #6423: [Bug][TubeMQ] Consumer registration failed due to BDB error
URL: https://github.com/apache/inlong/issues/6423
--
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: dev-unsubscribe@inlong.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [inlong] gosonzhang commented on issue #6423: [Bug][TubeMQ] Consumer registration failed due to BDB error
Posted by GitBox <gi...@apache.org>.
gosonzhang commented on issue #6423:
URL: https://github.com/apache/inlong/issues/6423#issuecomment-1305135805
Thanks @FvvSuu,you are the best!
--
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: commits-unsubscribe@inlong.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org