move test data to target dir

Author: novakov-alexey

modules/flink-common-api/src/test/resources/click.dat

@@ -11,6 +11,7 @@ import org.scalatest.matchers.should.Matchers
 
 import java.io.ByteArrayOutputStream
 import java.nio.file.{Files, Path}
+import java.io.FileInputStream
 
 class SchemaEvolutionTest extends AnyFlatSpec with Matchers {
   private implicit val newClickTypeInfo: TypeInformation[Click] = deriveTypeInformation[Click]
@@ -49,15 +50,18 @@ class SchemaEvolutionTest extends AnyFlatSpec with Matchers {
     modifiedResult shouldBe modifiedExpected
   }
 
-  ignore should "generate blob for event=click+purchase" in {
+  def generateBlobForEvent() =  {
     val buffer          = new ByteArrayOutputStream()
     val eventSerializer = createSerializer[Event]
     eventSerializer.serialize(Click("p1", clicks), new DataOutputViewStreamWrapper(buffer))
-    Files.write(Path.of("src/test/resources/click.dat"), buffer.toByteArray)
+    val path = Path.of("target/test/resources/click.dat")
+    Files.createDirectories(path.getParent())
+    Files.write(path, buffer.toByteArray)
   }
 
   it should "decode click when we added view" in {
-    val buffer = this.getClass.getResourceAsStream("/click.dat")
+    generateBlobForEvent()
+    val buffer = new FileInputStream("target/test/resources/click.dat")
     val click  = createSerializer[Event].deserialize(new DataInputViewStreamWrapper(buffer))
     click shouldBe Click("p1", clicks)
   }

modules/flink-common-api/src/test/resources/old-serializer-snapshot.dat

@@ -16,6 +16,7 @@ import java.io.{ByteArrayInputStream, ByteArrayOutputStream}
 import java.net.URLClassLoader
 import java.nio.file.{Files, Paths}
 import java.util.UUID
+import java.io.FileInputStream
 
 class SerializerSnapshotTest extends AnyFlatSpec with Matchers {
 
@@ -78,7 +79,7 @@ class SerializerSnapshotTest extends AnyFlatSpec with Matchers {
     }
   }
 
-  ignore should "serialize old serialization with the old serializer snapshot" in {
+  def serializeWithOldSerializer() = {
     val uuid                 = UUID.fromString("4daf2791-abbe-420f-9594-f57ded1fee8c")
     val expectedData         = OuterClass(Map(uuid -> List(SimpleClass2("a", 1))))
     val outerClassSerializer = implicitly[TypeSerializer[OuterClass]]
@@ -90,15 +91,18 @@ class SerializerSnapshotTest extends AnyFlatSpec with Matchers {
 
     // Serialize the data
     outerClassSerializer.serialize(expectedData, out)
-    Files.write(Paths.get("modules/flink-1-api/src/test/resources/old-serializer-snapshot.dat"), out.getSharedBuffer)
+    val path = Paths.get("target/test/resources/old-serializer-snapshot.dat")
+    Files.createDirectories(path.getParent())
+    Files.write(path, out.getSharedBuffer)
   }
 
   it should "deserialize old serialization with the new serializer snapshot" in {
+    serializeWithOldSerializer()
     val uuid         = UUID.fromString("4daf2791-abbe-420f-9594-f57ded1fee8c")
     val expectedData = OuterClass(Map(uuid -> List(SimpleClass2("a", 1))))
 
     // Deserialize the old serialization
-    val buffer               = getClass.getResourceAsStream("/old-serializer-snapshot.dat").readAllBytes()
+    val buffer               = new FileInputStream("target/test/resources/old-serializer-snapshot.dat").readAllBytes()
     val in                   = new DataInputDeserializer(buffer)
     val deserializedSnapshot = TypeSerializerSnapshot
       .readVersionedSnapshot[OuterClass](in, getClass.getClassLoader) // Flink always calls this