[ https://issues.apache.org/jira/browse/FLINK-32582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Matthias Pohl updated FLINK-32582: ---------------------------------- 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. was: The externalization of connectors made 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. > Move TypeSerializerUpgradeTestBase from Kafka connector into > flink-connector-common > ----------------------------------------------------------------------------------- > > Key: FLINK-32582 > URL: https://issues.apache.org/jira/browse/FLINK-32582 > Project: Flink > Issue Type: Improvement > Components: Connectors / Common > Reporter: Matthias Pohl > Priority: Minor > Labels: auto-deprioritized-major, pull-request-available > > 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. -- This message was sent by Atlassian Jira (v8.20.10#820010)