You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by "andyyumiao (via GitHub)" <gi...@apache.org> on 2023/12/28 09:15:59 UTC
[I] The message queue is not in assigned list [rocketmq-flink]
andyyumiao opened a new issue, #107:
URL: https://github.com/apache/rocketmq-flink/issues/107
I got the error when i consume rocketmq message in flink job：
```
Caused by: org.apache.rocketmq.client.exception.MQClientException: The message queue is not in assigned list, message queue: MessageQueue [topic=yumiao1205, brokerName=broker-a, queueId=1]
For more information, please visit the url, https://rocketmq.apache.org/docs/bestPractice/06FAQ
```
My rocketmq version: 5.1.1
flink version: 1.15.0
--
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@rocketmq.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] The message queue is not in assigned list [rocketmq-flink]
Posted by "ping-cai (via GitHub)" <gi...@apache.org>.
ping-cai commented on issue #107:
URL: https://github.com/apache/rocketmq-flink/issues/107#issuecomment-2154250518
it seens do nothing! this brantch 'main-latest' still exist! who can help fix this problem
RocketMQ Version:4.9.2
Flink Version: 1.15.2
problem details:
Caused by: org.apache.rocketmq.client.exception.MQClientException: The message queue is not in assigned list, message queue: MessageQueue [topic=tp_ld_driver_behavior_score_change, brokerName=broker-onlinemq1-d, queueId=0]
For more information, please visit the url, http://rocketmq.apache.org/docs/faq/
I guess this issue comes from the class 'DefaultLitePullConsumer',Previously, it was DefaultMQPullConsumer，This class will be removed in 2022, and a better implementation {@link DefaultLitePullConsumer} is recommend to use
--
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@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] The message queue is not in assigned list [rocketmq-flink]
Posted by "loserwang1024 (via GitHub)" <gi...@apache.org>.
loserwang1024 commented on issue #107:
URL: https://github.com/apache/rocketmq-flink/issues/107#issuecomment-2024830850
> See #96
It seems do nothing!
--
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@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] The message queue is not in assigned list [rocketmq-flink]
Posted by "madi1819 (via GitHub)" <gi...@apache.org>.
madi1819 commented on issue #107:
URL: https://github.com/apache/rocketmq-flink/issues/107#issuecomment-1996787602
I have also encountered this problem. Has it been resolved
--
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@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] The message queue is not in assigned list [rocketmq-flink]
Posted by "cj495840252 (via GitHub)" <gi...@apache.org>.
cj495840252 commented on issue #107:
URL: https://github.com/apache/rocketmq-flink/issues/107#issuecomment-1986753572
I also encounter this error， it's seem that still not solved
--
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@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] The message queue is not in assigned list [rocketmq-flink]
Posted by "humkum (via GitHub)" <gi...@apache.org>.
humkum commented on issue #107:
URL: https://github.com/apache/rocketmq-flink/issues/107#issuecomment-1991610589
See https://github.com/apache/rocketmq-flink/pull/96
--
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@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] The message queue is not in assigned list [rocketmq-flink]
Posted by "cj495840252 (via GitHub)" <gi...@apache.org>.
cj495840252 commented on issue #107:
URL: https://github.com/apache/rocketmq-flink/issues/107#issuecomment-1991885691
> See #96
hi, good morning , this is my setting
--
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@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] The message queue is not in assigned list [rocketmq-flink]
Posted by "liangjw (via GitHub)" <gi...@apache.org>.
liangjw commented on issue #107:
URL: https://github.com/apache/rocketmq-flink/issues/107#issuecomment-2295178541
Is this bug fixed? I have encountered this issue and found the messagequeue shoud be assigned. But I cant find any assined code.
The following code is runnable if assign the queue to consumer manually:
` Collection<MessageQueue> totalQueues = consumer.fetchMessageQueues(topic);
consumer.assign(totalQueues);
consumer.seekToEnd(totalQueues.iterator().next());`
--
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@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] The message queue is not in assigned list [rocketmq-flink]
Posted by "cj495840252 (via GitHub)" <gi...@apache.org>.
cj495840252 commented on issue #107:
URL: https://github.com/apache/rocketmq-flink/issues/107#issuecomment-1991878391
I am still have this error
while i run the simpleConsumer it's working normally, it's mean can connect rocketmq?
it's still failed while I run the ConnectorExample
RocketMQ: 5.0.0
```
2024-03-12 23:05:42 WARN [ Source: Custom Source (1/2)#0] [e.flink.runtime.taskmanager.Task] Source: Custom Source (1/2)#0 (ea15ccd58a1ef50baebef0860ee2e52b) switched from INITIALIZING to FAILED with failure cause: org.apache.rocketmq.client.exception.MQClientException: The message queue is not in assigned list, message queue: MessageQueue [topic=test, brokerName=broker-a, queueId=1]
For more information, please visit the url, https://rocketmq.apache.org/docs/bestPractice/06FAQ
at org.apache.rocketmq.client.impl.consumer.DefaultLitePullConsumerImpl.seek(DefaultLitePullConsumerImpl.java:660)
at org.apache.rocketmq.client.impl.consumer.DefaultLitePullConsumerImpl.seekToEnd(DefaultLitePullConsumerImpl.java:693)
at org.apache.rocketmq.client.consumer.DefaultLitePullConsumer.seekToEnd(DefaultLitePullConsumer.java:394)
at org.apache.flink.connector.rocketmq.legacy.RocketMQSourceFunction.initOffsets(RocketMQSourceFunction.java:394)
at org.apache.flink.connector.rocketmq.legacy.RocketMQSourceFunction.open(RocketMQSourceFunction.java:246)
at org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34)
at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:100)
at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:107)
at org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:700)
at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.call(StreamTaskActionExecutor.java:100)
at org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:676)
at org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:643)
at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948)
at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:917)
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:563)
at java.lang.Thread.run(Thread.java:750)
```
--
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@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] The message queue is not in assigned list [rocketmq-flink]
Posted by "madi1819 (via GitHub)" <gi...@apache.org>.
madi1819 commented on issue #107:
URL: https://github.com/apache/rocketmq-flink/issues/107#issuecomment-1996795906
> See #96
this is my test code
--
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@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org