Update scalafmt-core to 3.9.9 (#274)

* Update scalafmt-core to 3.9.9

* Reformat with scalafmt 3.9.9

Executed command: scalafmt --non-interactive

* Add 'Reformat with scalafmt 3.9.9' to .git-blame-ignore-revs

Author: scala-steward

.git-blame-ignore-revs

@@ -39,3 +39,6 @@ a82026bb66f0e17cf76f2d91c6ea286431bbbd31
 
 # Scala Steward: Reformat with scalafmt 3.9.8
 5dbfede26b72e6f3b64d3fc6a635ab5707fb4316
+
+# Scala Steward: Reformat with scalafmt 3.9.9
+b83264042216c7d83b73247b8b7a998902ec26d5

.scalafmt.conf

@@ -1,6 +1,6 @@
 style       = defaultWithAlign
 maxColumn   = 120
-version = 3.9.8
+version = 3.9.9
 assumeStandardLibraryStripMargin = true
 align.stripMargin = true
 runner.dialect = scala3

modules/flink-1-api/src/main/scala-3/org/apache/flinkx/api/LowPrioImplicits.scala

@@ -39,12 +39,14 @@ private[api] trait LowPrioImplicits extends TaggedDerivation[TypeInformation]:
           else
             new CaseClassSerializer[T & Product](
               clazz = clazz,
-              scalaFieldSerializers = IArray.genericWrapArray(ctx.params.map { p =>
-                val ser = p.typeclass.createSerializer(config)
-                if (p.annotations.exists(_.isInstanceOf[nullable])) {
-                  NullableSerializer.wrapIfNullIsNotSupported(ser, true)
-                } else ser
-              }).toArray,
+              scalaFieldSerializers = IArray
+                .genericWrapArray(ctx.params.map { p =>
+                  val ser = p.typeclass.createSerializer(config)
+                  if (p.annotations.exists(_.isInstanceOf[nullable])) {
+                    NullableSerializer.wrapIfNullIsNotSupported(ser, true)
+                  } else ser
+                })
+                .toArray,
               isCaseClassImmutable = isCaseClassImmutable(clazz, ctx.params.map(_.label))
             )
         val ti = new ProductTypeInformation[T & Product](

modules/flink-1-api/src/test/scala/org/apache/flinkx/api/SerializerSnapshotTest.scala

@@ -157,7 +157,7 @@ class SerializerSnapshotTest extends AnyFlatSpec with Matchers {
       .readVersionedSnapshot[WithDefault](input, getClass.getClassLoader) // Flink always calls this
 
     // Deserialize the old data with the new serializer
-    val newSerializer = implicitly[TypeSerializer[WithDefault]]
+    val newSerializer    = implicitly[TypeSerializer[WithDefault]]
     val deserializedData = newSerializer.deserialize(input)
     deserializedData should be(expectedData)
 

modules/flink-2-api/src/main/scala-3/org/apache/flinkx/api/LowPrioImplicits.scala

@@ -39,12 +39,14 @@ private[api] trait LowPrioImplicits extends TaggedDerivation[TypeInformation]:
           else
             new CaseClassSerializer[T & Product](
               clazz = clazz,
-              scalaFieldSerializers = IArray.genericWrapArray(ctx.params.map { p =>
-                val ser = p.typeclass.createSerializer(config)
-                if (p.annotations.exists(_.isInstanceOf[nullable])) {
-                  NullableSerializer.wrapIfNullIsNotSupported(ser, true)
-                } else ser
-              }).toArray,
+              scalaFieldSerializers = IArray
+                .genericWrapArray(ctx.params.map { p =>
+                  val ser = p.typeclass.createSerializer(config)
+                  if (p.annotations.exists(_.isInstanceOf[nullable])) {
+                    NullableSerializer.wrapIfNullIsNotSupported(ser, true)
+                  } else ser
+                })
+                .toArray,
               isCaseClassImmutable = isCaseClassImmutable(clazz, ctx.params.map(_.label))
             )
         val ti = new ProductTypeInformation[T & Product](

modules/flink-common-api/src/test/scala/org/apache/flinkx/api/serializer/CaseClassSerializerTest.scala

@@ -92,16 +92,16 @@ class CaseClassSerializerTest extends AnyFlatSpec with Matchers {
   }
 
   it should "copy the serialized stream" in {
-    val serializer = new CaseClassSerializer[Immutable](classOf[Immutable], Array(StringSerializer.INSTANCE), true)
+    val serializer      = new CaseClassSerializer[Immutable](classOf[Immutable], Array(StringSerializer.INSTANCE), true)
     val outerSerializer = new CaseClassSerializer[OuterMutable](classOf[OuterMutable], Array(serializer), true)
-    val expectedData = OuterMutable(Immutable("a"))
+    val expectedData    = OuterMutable(Immutable("a"))
 
     val output = new DataOutputSerializer(1024)
     outerSerializer.serialize(expectedData, output)
-    val input = new DataInputDeserializer(output.getSharedBuffer)
+    val input     = new DataInputDeserializer(output.getSharedBuffer)
     val newOutput = new DataOutputSerializer(1024)
     outerSerializer.copy(input, newOutput)
-    val newInput = new DataInputDeserializer(newOutput.getSharedBuffer)
+    val newInput   = new DataInputDeserializer(newOutput.getSharedBuffer)
     val resultData = outerSerializer.deserialize(newInput)
 
     resultData shouldEqual expectedData