Flink source support detect bucket number change #2104
Description
Search before asking
- I searched in the issues and found nothing similar.
Motivation
After support rescale bucket in #1554, Flink source should have the ability to detect the bucket change of table or partition.
Solution
No response
Anything else?
No response
Willingness to contribute
- I'm willing to submit a PR!