[Feature] Add itcase to test restoring for savepoint state.

[loserwang1024]

Search before asking

• I searched in the issues and found nothing similar.

Motivation

Currenly, flink connector lacks the itcase to test restoring for savepoint state.

Solution

No response

Anything else?

No response

Willingness to contribute

• I'm willing to submit a PR!

[kaori-seasons]

Hello, is there anyone taking over this job? I want to try it.

[wuchong]

@kaori-seasons assigned to you. Do you have any idea about how to implement IT cases for verifying source connector recovery?

[wuchong]

@kaori-seasons Flink provides a connector testing framework flink-connector-test-utils that provides basic classes SourceTestSuiteBase and SinkTestSuiteBase. These classes already define basic tests including restoring, savepoint, rescaling, failover, etc. We can try to extend the test classes.

https://github.com/apache/flink/blob/release-1.20/flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/testsuites/SourceTestSuiteBase.java#L104

[kaori-seasons]

@kaori-seasons Flink provides a connector testing framework flink-connector-test-utils that provides basic classes SourceTestSuiteBase and SinkTestSuiteBase. These classes already define basic tests including restoring, savepoint, rescaling, failover, etc. We can try to extend the test classes.

https://github.com/apache/flink/blob/release-1.20/flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/testsuites/SourceTestSuiteBase.java#L104

Okay, thank you very much for your suggestion. I will conduct research and then carry out related work