Re: [I] The message queue is not in assigned list [rocketmq-flink]

[via GitHub]

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?
   
![image](https://github.com/apache/rocketmq-flink/assets/63491689/141bb5c8-feea-4d1d-83ed-cb7e5951c7ca)
   
   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-unsubscr...@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org