[Feature]: Support switch from Changestore to Logstore automatically for flink source

[zhoujinsong]

Description

Support switch from Changestore to Logstore automatically for flink source

Use case/motivation

Arctic use Changestore and Logstore to store CDC messages. Logstore use MQ(eg: Kafka) to distribute real-time cdc message. Changestore use iceberg table to store cdc message for analyse and provide near real-time incremental pull. In really use case, Logstore store message for several days and Changestore store message for a longer time. Flink source should support to read Changestore for early CDC messages and switch to Logstore when catch it up.

Describe the solution

• Support to config the reading start time for Flink source
• Flink source determin read Changestore or Logstore according reading start time
• Flink source should transfer from Changestore to Logstore when catch it up.

Subtasks

• [x] #969

Related issues

No response

Are you willing to submit a PR?

• [ ] Yes I am willing to submit a PR!

Code of Conduct

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

[github-actions[bot]]

This issue has been automatically marked as stale because it has been open for 180 days with no activity. It will be closed in next 14 days if no further activity occurs. To permanently prevent this issue from being considered stale, add the label 'not-stale', but commenting on the issue is preferred when possible.