Reformat with scalafmt 3.9.10

Executed command: scalafmt --non-interactive

Author: scala-steward

modules/flink-common-api/src/main/scala/org/apache/flinkx/api/function/util/WrappingFunction.scala

@@ -3,16 +3,16 @@ package org.apache.flinkx.api.function.util
 import org.apache.flink.api.common.functions.util.FunctionUtils
 import org.apache.flink.api.common.functions.{AbstractRichFunction, Function, OpenContext, RuntimeContext}
 
-
-/**
- * Wrapper of [[Function]].
- *
- * Created to replace `org.apache.flink.api.java.operators.translation.WrappingFunction` in Flink 1.x that was moved to
- * `org.apache.flink.api.common.functions.WrappingFunction` in Flink 2.x making it not cross-compatible.
- *
- * @tparam T the type of the wrapped function.
- * @param wrappedFunction the underlying function to be wrapped.
- */
+/** Wrapper of [[Function]].
+  *
+  * Created to replace `org.apache.flink.api.java.operators.translation.WrappingFunction` in Flink 1.x that was moved to
+  * `org.apache.flink.api.common.functions.WrappingFunction` in Flink 2.x making it not cross-compatible.
+  *
+  * @tparam T
+  *   the type of the wrapped function.
+  * @param wrappedFunction
+  *   the underlying function to be wrapped.
+  */
 class WrappingFunction[T <: Function](val wrappedFunction: T) extends AbstractRichFunction {
 
   override def open(openContext: OpenContext): Unit = {

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

@@ -28,7 +28,7 @@ class ListSerializer[T](child: TypeSerializer[T], clazz: Class[T]) extends Mutab
   override def getLength: Int                              = -1
   override def deserialize(source: DataInputView): List[T] = {
     var remaining = source.readInt()
-    val builder = List.newBuilder[T]
+    val builder   = List.newBuilder[T]
     builder.sizeHint(remaining)
     while (remaining > 0) {
       builder.addOne(child.deserialize(source))

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

@@ -156,7 +156,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-common-api/src/test/scala/org/apache/flinkx/api/TestUtils.scala

@@ -158,7 +158,7 @@ trait TestUtils extends Matchers with Inspectors {
 
   @tailrec
   private def getAllFields[T](typeClass: Class[T], fields: Array[Field] = Array.empty): Array[Field] = {
-    val allFields  = fields ++ typeClass.getDeclaredFields
+    val allFields = fields ++ typeClass.getDeclaredFields
       .filter(isInstanceField)
       .filter(isNotBitmapField)
       .filter(isNotOverriddenField(_, fields))