Update scalafmt-core to 3.9.6 (#249)

* Update scalafmt-core to 3.9.6

* Reformat with scalafmt 3.9.6

Executed command: scalafmt --non-interactive

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

Author: scala-steward

.git-blame-ignore-revs

@@ -30,3 +30,6 @@ ae9aadfa2b4779b5096a9004d6d7f5d9db2c2c7f
 
 # Scala Steward: Reformat with scalafmt 3.9.5
 86e22a329b56041cf014ca16e78ab03e8fd7df00
+
+# Scala Steward: Reformat with scalafmt 3.9.6
+9fd34d49283551ea5253cbe6177a10661be715d3

.scalafmt.conf

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

build.sbt

@@ -114,8 +114,8 @@ lazy val `scala-api-common` = (project in file("modules/flink-common-api"))
     crossScalaVersions := crossVersions,
     libraryDependencies ++= Seq(
       "org.apache.flink" % "flink-streaming-java" % flinkVersion1 % Provided,
-      "org.scalatest"    %% "scalatest"                   % "3.2.19"     % Test,
-      "ch.qos.logback"    % "logback-classic"             % "1.5.17"     % Test
+      "org.scalatest"   %% "scalatest"            % "3.2.19"      % Test,
+      "ch.qos.logback"   % "logback-classic"      % "1.5.17"      % Test
     )
   )
 

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

@@ -91,7 +91,7 @@ class SerializerSnapshotTest extends AnyFlatSpec with Matchers {
     val output = new DataOutputViewStreamWrapper(buffer)
     TypeSerializerSnapshot.writeVersionedSnapshot(output, snap)
     output.close()
-    val input = new DataInputViewStreamWrapper(new ByteArrayInputStream(buffer.toByteArray))
+    val input     = new DataInputViewStreamWrapper(new ByteArrayInputStream(buffer.toByteArray))
     val deserSnap = TypeSerializerSnapshot.readVersionedSnapshot[T](input, cl)
     deserSnap.restoreSerializer()
   }

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

@@ -14,10 +14,14 @@ trait TestUtils extends Matchers with Inspectors {
     val out = new ByteArrayOutputStream()
     ser.serialize(in, new DataOutputViewStreamWrapper(out))
     val snapBytes = new ByteArrayOutputStream()
-    TypeSerializerSnapshot.writeVersionedSnapshot(new DataOutputViewStreamWrapper(snapBytes), ser.snapshotConfiguration())
+    TypeSerializerSnapshot.writeVersionedSnapshot(
+      new DataOutputViewStreamWrapper(snapBytes),
+      ser.snapshotConfiguration()
+    )
     val restoredSnapshot = TypeSerializerSnapshot.readVersionedSnapshot[T](
       new DataInputViewStreamWrapper(new ByteArrayInputStream(snapBytes.toByteArray)),
-      ser.getClass.getClassLoader)
+      ser.getClass.getClassLoader
+    )
     val restoredSerializer = restoredSnapshot.restoreSerializer()
     val copy = restoredSerializer.deserialize(new DataInputViewStreamWrapper(new ByteArrayInputStream(out.toByteArray)))
     in shouldBe copy

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

@@ -28,7 +28,7 @@ class CoproductSerializerTest extends AnyFlatSpec with Matchers {
 
   it should "return the same instance when immutable" in {
     val immutableSerializer = implicitly[TypeSerializer[Immutable]]
-    val expectedData = Immutable2("a")
+    val expectedData        = Immutable2("a")
 
     val resultData = immutableSerializer.copy(expectedData)
 
@@ -37,7 +37,7 @@ class CoproductSerializerTest extends AnyFlatSpec with Matchers {
 
   it should "copy the instance when mutable" in {
     val mutableSerializer = implicitly[TypeSerializer[Mutable]]
-    val expectedData = Mutable1("a")
+    val expectedData      = Mutable1("a")
 
     val resultData = mutableSerializer.copy(expectedData)
 
@@ -47,7 +47,7 @@ class CoproductSerializerTest extends AnyFlatSpec with Matchers {
 
   it should "return the same instance when immutable even if some other subtypes of the sealed trait are mutable" in {
     val mutableSerializer = implicitly[TypeSerializer[Mutable]]
-    val expectedData = Immutable3("a")
+    val expectedData      = Immutable3("a")
 
     val resultData = mutableSerializer.copy(expectedData)
 

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

@@ -55,7 +55,7 @@ class EitherSerializer[A, B](
   override def copy(from: Either[A, B]): Either[A, B] = from match {
     case Left(a)  => if (leftSerializer.isImmutableType) from else Left(leftSerializer.copy(a))
     case Right(b) => if (rightSerializer.isImmutableType) from else Right(rightSerializer.copy(b))
-    case null => from
+    case null     => from
   }
 
   override def copy(source: DataInputView, target: DataOutputView): Unit = {

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

@@ -49,7 +49,7 @@ class CaseClassSerializerTest extends AnyFlatSpec with Matchers {
 
   it should "copy the case class when mutable" in {
     val mutableSerializer = new CaseClassSerializer[Mutable](classOf[Mutable], Array(StringSerializer.INSTANCE), false)
-    val expectedData = Mutable("a")
+    val expectedData      = Mutable("a")
 
     val resultData = mutableSerializer.copy(expectedData)