1328837476-hug commented on issue #12138: URL: https://github.com/apache/seatunnel/issues/12138#issuecomment-5557902740
Hi @DanielLeens, thanks for the detailed investigation. I’m interested in working on this issue. I plan to reproduce the problem with `RocketMqIT#testSourceRocketMqRestore`, initialize the enumerator’s restored queue state from `RocketMqSourceState`, and add regression coverage to ensure `run()` cannot rediscover and reassign queues already recorded in the checkpoint. Are you already working on a fix, or would it be okay for me to take this issue? -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
