You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2021/01/28 13:30:14 UTC
[GitHub] [rocketmq-externals] CCThinkBank opened a new issue #674: Flink-RocketMQ Source
CCThinkBank opened a new issue #674:
URL: https://github.com/apache/rocketmq-externals/issues/674
See http://rocketmq.apache.org/docs/faq/ for further details.
at org.apache.rocketmq.client.impl.MQAdminImpl.fetchSubscribeMessageQueues(MQAdminImpl.java:177)
at org.apache.rocketmq.client.impl.consumer.DefaultMQPullConsumerImpl.fetchSubscribeMessageQueues(DefaultMQPullConsumerImpl.java:147)
at org.apache.rocketmq.client.consumer.DefaultMQPullConsumer.fetchSubscribeMessageQueues(DefaultMQPullConsumer.java:290)
at org.apache.rocketmq.flink.RocketMQSource.run(RocketMQSource.java:186)
at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:100)
at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:63)
at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:196)
Caused by: org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to [1677373804099757.mqrest.cn-shanghai.aliyuncs.com] failed
at org.apache.rocketmq.remoting.netty.NettyRemotingClient.getAndCreateNameserverChannel(NettyRemotingClient.java:445)
at org.apache.rocketmq.remoting.netty.NettyRemotingClient.getAndCreateChannel(NettyRemotingClient.java:400)
at org.apache.rocketmq.remoting.netty.NettyRemotingClient.invokeSync(NettyRemotingClient.java:369)
at org.apache.rocketmq.client.impl.MQClientAPIImpl.getTopicRouteInfoFromNameServer(MQClientAPIImpl.java:1363)
at org.apache.rocketmq.client.impl.MQClientAPIImpl.getTopicRouteInfoFromNameServer(MQClientAPIImpl.java:1353)
at org.apache.rocketmq.client.impl.MQAdminImpl.fetchSubscribeMessageQueues(MQAdminImpl.java:166)
... 6 more
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-externals] vongosling edited a comment on issue #674: Flink-RocketMQ Source
Posted by GitBox <gi...@apache.org>.
vongosling edited a comment on issue #674:
URL: https://github.com/apache/rocketmq-externals/issues/674#issuecomment-776370177
ping @CCThinkBank If no detailed follow-up, I will close the issue temporarily.
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-externals] duhenglucky closed issue #674: Flink-RocketMQ Source
Posted by GitBox <gi...@apache.org>.
duhenglucky closed issue #674:
URL: https://github.com/apache/rocketmq-externals/issues/674
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-externals] lizhimins commented on issue #674: Flink-RocketMQ Source
Posted by GitBox <gi...@apache.org>.
lizhimins commented on issue #674:
URL: https://github.com/apache/rocketmq-externals/issues/674#issuecomment-771596192
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-externals] lizhimins commented on issue #674: Flink-RocketMQ Source
Posted by GitBox <gi...@apache.org>.
lizhimins commented on issue #674:
URL: https://github.com/apache/rocketmq-externals/issues/674#issuecomment-771596462
Can you report more details？
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-externals] lizhimins commented on issue #674: Flink-RocketMQ Source
Posted by GitBox <gi...@apache.org>.
lizhimins commented on issue #674:
URL: https://github.com/apache/rocketmq-externals/issues/674#issuecomment-771596192
Maybe you set wrong endpoint
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-externals] vongosling commented on issue #674: Flink-RocketMQ Source
Posted by GitBox <gi...@apache.org>.
vongosling commented on issue #674:
URL: https://github.com/apache/rocketmq-externals/issues/674#issuecomment-776370177
ping @CCThinkBank If any other follow-up, I will close the issue temporarily.
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org