luckydarnell

# In IntelliJ,every thing is ok,the log: 24/01/05 10:07:16 INFO org.apache.rocketmq.flink.source.enumerator.RocketMQSourceEnumerator: Starting the RocketMQSourceEnumerator for consumer group X without periodic partition discovery. 24/01/05 10:07:16 INFO org.apache.flink.runtime.source.coordinator.SourceCoordinator: Source Source: s(MQ)- **_registering...

> 修改死信队列perm值为6，使消息可读 1、没有创建死信队列 2、队列本身的perm值为6 现在的问题是我在idea里面跑是正常，启动集群在集群里面跑就有问题

I have tried several times and found that **_RocketMQSourceFunction_** interface can run normally。so I guess there are some bugs in the **_RocketMQSource_** interface。 + code ``` public static RocketMQSourceFunction createMqsource2(SourceCfg...