Flink source support detect bucket number change #2104

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!