[Bug][Sort] Hang up reader in snapshot phase when reducing paralleism

[EMsnap]

What happened

This bug happends when:
1、sort task runs in multi paralleism
2、sort task running in snapshot phase running mysql cdc
3、stop job and reduce paralleism and restart

the task will read one chunk and then read another one
the log tells that a binlog client starts twice
and then the second chunk won't be processed anymore

What you expected to happen

no hang up reader in snapshot phase when reducing paralleism

How to reproduce

This bug happends when:
1、sort task runs in multi paralleism
2、sort task running in snapshot phase running mysql cdc
3、stop job and reduce paralleism and restart

Environment

No response

InLong version

master

InLong Component

InLong Sort

Are you willing to submit PR?

• Yes, I am willing to submit a PR!

Code of Conduct

• I agree to follow this project's Code of Conduct