Identification of snapshot phase completion.

[debjeetsarkar]

If one wants to use flink-cdc-connector for snapshotting data from mysql and stop the process before going to the CDC phase, what is the ideal place to identify snapshot completion ?

For example: createDataEvents method in MySqlSnapshotSplitReadTask class tells that a given snapshot split task has completed. Where can one find to identify that the entire snapshotting is completed and now its going into the CDC phase ?