[refacto] Simplify unnecessary complex test in Flink 2

Author: arnaud-daroussin

modules/flink-2-api/src/test/scala/org/apache/flinkx/api/StreamExecutionEnvironmentTest.scala

@@ -9,8 +9,6 @@ import org.apache.flink.util.FlinkRuntimeException
 import org.scalatest.flatspec.AnyFlatSpec
 import org.scalatest.matchers.should.Matchers
 
-import scala.util.{Failure, Success, Try}
-
 class StreamExecutionEnvironmentTest extends AnyFlatSpec with Matchers with IntegrationTest {
 
   it should "create a stream from a source" in {
@@ -26,32 +24,19 @@ class StreamExecutionEnvironmentTest extends AnyFlatSpec with Matchers with Inte
   }
 
   it should "create a stream from a sequence" in {
-    import org.apache.flinkx.api.serializers._
+    import org.apache.flinkx.api.serializers.*
     val typeInfo = implicitly[TypeInformation[Long]]
 
     val stream = env.fromSequence(1, 100)
 
     stream.dataType shouldBe typeInfo
   }
 
-  "From Flink 1.19, TypeInformation.of(Class)" should "fail-fast trying to resolve Scala type" in {
-    Try(Class.forName("org.apache.flink.configuration.PipelineOptions").getField("SERIALIZATION_CONFIG")) match {
-      case Failure(_) => // Before Flink 1.19: no fail-fast, exception happens at execution
-        implicit val typeInfo: TypeInformation[Option[Int]] = TypeInformation.of(classOf[Option[Int]])
-        val stream                                          = env.fromElements(Some(1), None, Some(100))
-        val exception                                       = intercept[UnsupportedOperationException] {
-          stream.executeAndCollect(3)
-        }
-        exception.getMessage should startWith(
-          "Generic types have been disabled in the ExecutionConfig and type scala.Option is treated as a generic type."
-        )
-
-      case Success(_) => // From Flink 1.19: fail-fast at Scala type resolution
-        val exception = intercept[FlinkRuntimeException] {
-          TypeInformation.of(classOf[Option[Int]])
-        }
-        exception.getMessage should startWith("You are using a 'Class' to resolve 'scala.Option' Scala type.")
+  "TypeInformation.of(Class)" should "fail-fast trying to resolve Scala type" in {
+    val exception = intercept[FlinkRuntimeException] {
+      TypeInformation.of(classOf[Option[Int]])
     }
+    exception.getMessage should startWith("You are using a 'Class' to resolve 'scala.Option' Scala type.")
   }
 
   // --------------------------------------------------------------------------

modules/flink-common-api/src/main/scala/org/apache/flinkx/api/serializer/SeqSerializer.scala

@@ -3,12 +3,8 @@ package org.apache.flinkx.api.serializer
 import org.apache.flink.api.common.typeutils.{TypeSerializer, TypeSerializerSnapshot}
 import org.apache.flink.core.memory.{DataInputView, DataOutputView}
 
-import scala.reflect.ClassTag
-
 class SeqSerializer[T](child: TypeSerializer[T], clazz: Class[T]) extends MutableSerializer[Seq[T]] {
 
-  private implicit val classTag: ClassTag[T] = ClassTag(clazz)
-
   override val isImmutableType: Boolean = child.isImmutableType
 
   override def copy(from: Seq[T]): Seq[T] = {