You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@fluss.apache.org by ja...@apache.org on 2026/01/05 03:36:15 UTC
(fluss) branch main updated: [hotfix] Fix spotless checkstyle problems
This is an automated email from the ASF dual-hosted git repository.
jark pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git
The following commit(s) were added to refs/heads/main by this push:
new 3d46efadd [hotfix] Fix spotless checkstyle problems
3d46efadd is described below
commit 3d46efadde99c6cc31a13bcaf404fa081b473571
Author: Jark Wu <ja...@apache.org>
AuthorDate: Mon Jan 5 11:35:51 2026 +0800
[hotfix] Fix spotless checkstyle problems
---
.../main/scala/org/apache/fluss/spark/row/SparkAsFlussArray.scala | 5 +++--
.../src/main/scala/org/apache/fluss/spark/row/SparkAsFlussRow.scala | 3 ++-
2 files changed, 5 insertions(+), 3 deletions(-)
diff --git a/fluss-spark/fluss-spark-common/src/main/scala/org/apache/fluss/spark/row/SparkAsFlussArray.scala b/fluss-spark/fluss-spark-common/src/main/scala/org/apache/fluss/spark/row/SparkAsFlussArray.scala
index 4ef4a32e7..17d45ec02 100644
--- a/fluss-spark/fluss-spark-common/src/main/scala/org/apache/fluss/spark/row/SparkAsFlussArray.scala
+++ b/fluss-spark/fluss-spark-common/src/main/scala/org/apache/fluss/spark/row/SparkAsFlussArray.scala
@@ -17,9 +17,10 @@
package org.apache.fluss.spark.row
-import org.apache.fluss.row.{BinaryString, Decimal, InternalMap, TimestampLtz, TimestampNtz, InternalArray => FlussInternalArray, InternalRow => FlussInternalRow}
+import org.apache.fluss.row.{BinaryString, Decimal, InternalArray => FlussInternalArray, InternalMap, InternalRow => FlussInternalRow, TimestampLtz, TimestampNtz}
+
import org.apache.spark.sql.catalyst.util.{ArrayData => SparkArrayData}
-import org.apache.spark.sql.types.{StructType, ArrayType => SparkArrayType, DataType => SparkDataType}
+import org.apache.spark.sql.types.{ArrayType => SparkArrayType, DataType => SparkDataType, StructType}
/** Wraps a Spark [[SparkArrayData]] as a Fluss [[FlussInternalArray]]. */
class SparkAsFlussArray(arrayData: SparkArrayData, elementType: SparkDataType)
diff --git a/fluss-spark/fluss-spark-common/src/main/scala/org/apache/fluss/spark/row/SparkAsFlussRow.scala b/fluss-spark/fluss-spark-common/src/main/scala/org/apache/fluss/spark/row/SparkAsFlussRow.scala
index 8248692f3..3a5c9613c 100644
--- a/fluss-spark/fluss-spark-common/src/main/scala/org/apache/fluss/spark/row/SparkAsFlussRow.scala
+++ b/fluss-spark/fluss-spark-common/src/main/scala/org/apache/fluss/spark/row/SparkAsFlussRow.scala
@@ -17,7 +17,8 @@
package org.apache.fluss.spark.row
-import org.apache.fluss.row.{BinaryString, Decimal, InternalMap, TimestampLtz, TimestampNtz, InternalRow => FlussInternalRow}
+import org.apache.fluss.row.{BinaryString, Decimal, InternalMap, InternalRow => FlussInternalRow, TimestampLtz, TimestampNtz}
+
import org.apache.spark.sql.catalyst.{InternalRow => SparkInternalRow}
import org.apache.spark.sql.types.StructType