minor

eason-yuchen-liu · Jul 1, 2024 · 12298b2 · 12298b2
1 parent 75839ac
commit 12298b2
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...main/scala/org/apache/spark/sql/execution/datasources/v2/state/StatePartitionReader.scala b/...main/scala/org/apache/spark/sql/execution/datasources/v2/state/StatePartitionReader.scala
@@ -177,7 +177,8 @@ class StateStoreChangeDataPartitionReader(
     provider.close()
   }
 
-  private def unifyStateChangeDataRow(row: (RecordType, UnsafeRow, UnsafeRow, Long)): InternalRow = {
+  private def unifyStateChangeDataRow(row: (RecordType, UnsafeRow, UnsafeRow, Long)):
+    InternalRow = {
     val result = new GenericInternalRow(5)
     result.update(0, row._2)
     result.update(1, row._3)