[FLINK-32582] Move TypeSerializerUpgradeTestBase from Kafka connector into flink-connector-common

• Type: Improvement
• Status: Open
• Priority: Minor
• Resolution: Unresolved
• Component/s: Connectors / Common
• Labels: auto-deprioritized-major pull-request-available
• Assignee: Unassigned
• Reporter: Matthias Pohl
• Created: 12/Jul/23 07:04
• Updated: 11/Apr/24 10:04

Description

The externalization of connectors caused problems with the Flink's test data generation. The Kafka connector relied on TypeSerializerUpgradeTestBase for some test cases which was fine prior to FLINK-27518 where the test data generation was handled individually.

With FLINK-27518 the process was automated in Flink 1.18. For now, the TypeSerializerUpgradeTestBase class was just copied over into the Kafka connector since it was the only connector that would utilize this test base.

But we might want to provide a more generalized solution where the test base is provided by flink-connector-common to offer a generalized approach for any connector.

Issue Links

• is caused by: FLINK-32455 Breaking change in TypeSerializerUpgradeTestBase prevents flink-connector-kafka from building against 1.18-SNAPSHOT
• is caused by: FLINK-27518 Refactor migration tests to support version update automatically