[flink-connector-kafka] 05/27: [FLINK-27727][tests] Migrate TypeSerializerUpgradeTestBase to JUnit5

[martijnvisser]

This is an automated email from the ASF dual-hosted git repository.

martijnvisser pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-kafka.git

commit ab110243ad4c1c26fe34cc067e8af237eed07f8a
Author: Sergey Nuyanzin <snuyan...@gmail.com>
AuthorDate: Fri May 20 23:55:02 2022 +0200

    [FLINK-27727][tests] Migrate TypeSerializerUpgradeTestBase to JUnit5
---
 .../connectors/kafka/KafkaSerializerUpgradeTest.java         | 12 ++----------
 1 file changed, 2 insertions(+), 10 deletions(-)

diff --git 
a/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaSerializerUpgradeTest.java
 
b/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaSerializerUpgradeTest.java
index 4f8f6d7..0d89d39 100644
--- 
a/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaSerializerUpgradeTest.java
+++ 
b/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaSerializerUpgradeTest.java
@@ -26,8 +26,6 @@ import 
org.apache.flink.api.common.typeutils.TypeSerializerUpgradeTestBase;
 import 
org.apache.flink.streaming.connectors.kafka.internals.FlinkKafkaInternalProducer;
 
 import org.hamcrest.Matcher;
-import org.junit.runner.RunWith;
-import org.junit.runners.Parameterized;
 import org.mockito.Mockito;
 
 import java.util.ArrayList;
@@ -41,15 +39,9 @@ import static org.hamcrest.Matchers.is;
  * A {@link TypeSerializerUpgradeTestBase} for {@link 
FlinkKafkaProducer.TransactionStateSerializer}
  * and {@link FlinkKafkaProducer.ContextStateSerializer}.
  */
-@RunWith(Parameterized.class)
-public class KafkaSerializerUpgradeTest extends 
TypeSerializerUpgradeTestBase<Object, Object> {
+class KafkaSerializerUpgradeTest extends TypeSerializerUpgradeTestBase<Object, 
Object> {
 
-    public KafkaSerializerUpgradeTest(TestSpecification<Object, Object> 
testSpecification) {
-        super(testSpecification);
-    }
-
-    @Parameterized.Parameters(name = "Test Specification = {0}")
-    public static Collection<TestSpecification<?, ?>> testSpecifications() 
throws Exception {
+    public Collection<TestSpecification<?, ?>> createTestSpecifications() 
throws Exception {
 
         ArrayList<TestSpecification<?, ?>> testSpecifications = new 
ArrayList<>();
         for (FlinkVersion flinkVersion : MIGRATION_VERSIONS) {